Startseite Erkunden Hilfe
Registrieren Anmelden
bigdata
/
DataWorks-flow-touch
3
0
Fork 0
Dateien Issues 0 Pull-Requests 0 Wiki
Struktur: 2cb8d2f4de
Branches Tags
DataWorks-fl...
/
jobs
/
task-step01.yaml

task-step01.yaml 2.5 KB
Verlauf Originalformat

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182 
  1. # 公司基本信息、招投标、环保处罚、购地信息、地块公示、行政处罚-信用中国、行政处罚、土地抵押、土地转让
    2. 

  2. job:
    3. 

  3.   #------<公示催告:ODPS SQL
    4. 

  4.   - project: winhc_test
    5. 

  5.     flow: inc_company_public_announcement_sql
    6. 

  6.     task:
    7. 

  7.       - taskName: company_public_announcement2
    8. 

  8.         param:
    9. 

  9.           - _nodeId: 700003471556
    10. 

  10.             PROJECT: winhc_eci_dev
    11. 

  11.   #------>
    12. 

  12. 

  13.   - project: winhc_eci
    14. 

  14.     flow: company_judicial_sale
    15. 

  15.     task:
    16. 

  16. 

  17.       #run-1 司法拍卖前置任务
    18. 

  18.       - taskName: company_judicial_sale
    19. 

  19.         param:
    20. 

  20.           - _nodeId: 700003485951
    21. 

  21.             project: winhc_eci_dev
    22. 

  22.             tableName: company_judicial_sale
    23. 

  23. 

  24. 

  25. 

  26.   - project: winhc_eci
    27. 

  27.     flow: wenshu_detail_combine
    28. 

  28.     task:
    29. 

  29. 

  30.       #run-1 文书前置任务
    31. 

  31.       - taskName: wenshu_detail_combine
    32. 

  32.         param:
    33. 

  33.           - _nodeId: 700003495086
    34. 

  34.             project: winhc_eci_dev
    35. 

  35.             tableName: wenshu_detail_combine
    36. 

  36. 

  37.   - project: winhc_eci
    38. 

  38.     flow: company_incr_combine
    39. 

  39.     task:
    40. 

  40.       #专利增量合并
    41. 

  41.       - taskName: inc_company_patent_pre
    42. 

  42.         param:
    43. 

  43.           - _nodeId: 700003517752
    44. 

  44.             project: winhc_eci_dev
    45. 

  45.             source: winhc_eci.inc_ods_company_patent_pre
    46. 

  46.             target: winhc_eci_dev.inc_ods_company_patent
    47. 

  47. 

  48.       #终本案件增量合并
    49. 

  49.       - taskName: inc_ods_company_zxr_final_case_pre
    50. 

  50.         param:
    51. 

  51.           - _nodeId: 700003517752
    52. 

  52.             project: winhc_eci_dev
    53. 

  53.             source: winhc_eci.inc_ods_company_zxr_final_case_pre
    54. 

  54.             target: winhc_eci_dev.inc_ods_company_zxr_final_case
    55. 

  55.       #失信人增量合并
    56. 

  56.       - taskName: inc_ods_company_dishonest_info_pre
    57. 

  57.         param:
    58. 

  58.           - _nodeId: 700003517752
    59. 

  59.             project: winhc_eci_dev
    60. 

  60.             source: winhc_eci.inc_ods_company_dishonest_info_pre
    61. 

  61.             target: winhc_eci_dev.inc_ods_company_dishonest_info
    62. 

  62. 

  63.       #开庭公告增量合并
    64. 

  64.       - taskName: inc_ods_company_court_open_announcement_pre
    65. 

  65.         param:
    66. 

  66.           - _nodeId: 700003517752
    67. 

  67.             project: winhc_eci_dev
    68. 

  68.             source: winhc_eci.inc_ods_company_court_open_announcement_pre
    69. 

  69.             target: winhc_eci_dev.inc_ods_company_court_open_announcement
    70. 

  70.   #------<企业cid、自然人身份证补全:Spark
    71. 

  71.   - project: winhc_test
    72. 

  72.     flow: company_person_info_completion
    73. 

  73.     task:
    74. 

  74.       - taskName: company_cloze
    75. 

  75.         param:
    76. 

  76.           - _nodeId: 700003580841
    77. 

  77.             project: winhc_eci_dev
    78. 

  78.             flag: false
    79. 

  79.           - _nodeId: 700003578968
    80. 

  80.             project: winhc_eci_dev
    81. 

  81.             flag: false
    82. 

  82.   #------>
    83.