elink-star
/
esua-epdc-cloud
8
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

kettle修改-王公峰-2022-01-20

feature/dangjian
wanggongfeng 4 years ago
parent
6b0e6b6543
commit
b170eafc79
1 changed files with 517 additions and 182 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 699
      esua-epdc/kettle-Code/dcp_job/epmet_gov_project/project_staff.ktr

699
esua-epdc/kettle-Code/dcp_job/epmet_gov_project/project_staff.ktr
View File

@ -580,142 +580,14 @@
</connection>
<order>
<hop>
<from>获取项目节点相关人员最新更新时间</from>
<to>获取市北项目节点相关人员</to>
<enabled>Y</enabled>
</hop>
<hop>
<from>获取市北项目节点相关人员</from>
<to>插入 / 更新</to>
<from>获取项目节点相关人员信息</from>
<to>表输出</to>
<enabled>Y</enabled>
</hop>
</order>
<step>
<name>插入 / 更新</name>
<type>InsertUpdate</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<connection>epmet_gov_project</connection>
<commit>100</commit>
<update_bypassed>N</update_bypassed>
<lookup>
<schema/>
<table>project_staff</table>
<key>
<name>PROCESS_ID</name>
<field>PROCESS_ID</field>
<condition>=</condition>
<name2/>
</key>
<value>
<name>ID</name>
<rename>ID</rename>
<update>N</update>
</value>
<value>
<name>PROJECT_ID</name>
<rename>PROJECT_ID</rename>
<update>Y</update>
</value>
<value>
<name>PROCESS_ID</name>
<rename>PROCESS_ID</rename>
<update>Y</update>
</value>
<value>
<name>CUSTOMER_ID</name>
<rename>CUSTOMER_ID</rename>
<update>Y</update>
</value>
<value>
<name>ORG_ID</name>
<rename>ORG_ID</rename>
<update>Y</update>
</value>
<value>
<name>DEPARTMENT_ID</name>
<rename>DEPARTMENT_ID</rename>
<update>Y</update>
</value>
<value>
<name>GRID_ID</name>
<rename>GRID_ID</rename>
<update>Y</update>
</value>
<value>
<name>ORG_ID_PATH</name>
<rename>ORG_ID_PATH</rename>
<update>Y</update>
</value>
<value>
<name>STAFF_ID</name>
<rename>STAFF_ID</rename>
<update>Y</update>
</value>
<value>
<name>DEPARTMENT_NAME</name>
<rename>DEPARTMENT_NAME</rename>
<update>Y</update>
</value>
<value>
<name>IS_HANDLE</name>
<rename>IS_HANDLE</rename>
<update>Y</update>
</value>
<value>
<name>DEL_FLAG</name>
<rename>DEL_FLAG</rename>
<update>Y</update>
</value>
<value>
<name>REVISION</name>
<rename>REVISION</rename>
<update>Y</update>
</value>
<value>
<name>CREATED_BY</name>
<rename>CREATED_BY</rename>
<update>Y</update>
</value>
<value>
<name>CREATED_TIME</name>
<rename>CREATED_TIME</rename>
<update>Y</update>
</value>
<value>
<name>UPDATED_BY</name>
<rename>UPDATED_BY</rename>
<update>Y</update>
</value>
<value>
<name>UPDATED_TIME</name>
<rename>UPDATED_TIME</rename>
<update>Y</update>
</value>
</lookup>
<attributes/>
<cluster_schema/>
<remotesteps>
<input>
</input>
<output>
</output>
</remotesteps>
<GUI>
<xloc>832</xloc>
<yloc>176</yloc>
<draw>Y</draw>
</GUI>
</step>
<step>
<name>获取市北项目节点相关人员</name>
<type>DBJoin</type>
<name>获取项目节点相关人员信息</name>
<type>TableInput</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
@ -725,66 +597,49 @@
<schema_name/>
</partitioning>
<connection>esua_epdc_events</connection>
<rowlimit>0</rowlimit>
<sql>select
<sql>SELECT
MD5(UUID()) ID,
ip.ITEM_ID PROJECT_ID,
ip.ID PROCESS_ID,
(select dct.dict_value from esua_epdc_admin.sys_dict dct where dct.del_flag = 0 and dct.dict_type = 'dcp' and dct.pid != 0) CUSTOMER_ID,
IF(dept.type_key like '%_party' and dept.type_key != 'grid_party' ,ip.HANDLER_DEPT_ID,'') as ORG_ID,
IF(dept.type_key like '%_dept' ,ip.HANDLER_DEPT_ID,'') as DEPARTMENT_ID,
IF(dept.type_key = 'grid_party' ,ip.HANDLER_DEPT_ID,'') as GRID_ID,
concat(REPLACE(dept.pids,',',':'),':',ip.HANDLER_DEPT_ID) as ORG_ID_PATH,
IF(dept.type_key like '%_party' and dept.type_key != 'grid_party' ,pro.HANDLER_DEPT_ID,'') as ORG_ID,
IF(dept.type_key like '%_dept' ,pro.HANDLER_DEPT_ID,'') as DEPARTMENT_ID,
IF(dept.type_key = 'grid_party' ,pro.HANDLER_DEPT_ID,'') as GRID_ID,
concat(REPLACE(dept.pids,',',':'),':',pro.HANDLER_DEPT_ID) as ORG_ID_PATH,
ip.CREATED_BY STAFF_ID,
ip.HANDLER_DEPT DEPARTMENT_NAME,
'handle' IS_HANDLE,
'unhandled' IS_HANDLE,
ip.DEL_FLAG,
ip.REVISION,
ip.CREATED_BY,
ip.CREATED_TIME,
ip.UPDATED_BY,
ip.UPDATED_TIME
from epdc_item_handle_process ip
left join esua_epdc_admin.sys_dept dept on dept.ID = ip.HANDLER_DEPT_ID and dept.del_flag = 0
where ip.DEL_FLAG = 0
and ip.UPDATED_TIME > ?
from (
select
t.processId,
(case when t.DEPT_ID is null then t.HANDLER_DEPT_ID else t.DEPT_ID end) as HANDLER_DEPT_ID
from (
SELECT
it.ID,
ip.ITEM_ID,
ip.CREATED_TIME,
ip.ID processId,
ip.HANDLER_DEPT_ID,
(select max(CREATED_TIME) from epdc_item_handle_process where DEL_FLAG = 0 and STATE = 0 and ITEM_ID = ip.ITEM_ID ) maxTime,
id.DEPT_ID
from epdc_item it
left join epdc_item_handle_process ip on ip.ITEM_ID = it.ID and ip.DEL_FLAG = 0
left join epdc_item_dept id on id.ITEM_HANDLE_ID = ip.id and id.DEL_FLAG = 0
where it.DEL_FLAG = 0
and it.ITEM_STATE = 0
and ip.STATE = 0
group by ip.CREATED_TIME
) t where t.CREATED_TIME = t.maxTime
) pro
left join epdc_item_handle_process ip on ip.ID = pro.processId and ip.DEL_FLAG = 0
left join esua_epdc_admin.sys_dept dept on dept.ID = pro.HANDLER_DEPT_ID and dept.del_flag = 0
</sql>
<outer_join>N</outer_join>
<replace_vars>N</replace_vars>
<parameter>
<field>
<name>START_DATE</name>
<type>Date</type>
</field>
</parameter>
<attributes/>
<cluster_schema/>
<remotesteps>
<input>
</input>
<output>
</output>
</remotesteps>
<GUI>
<xloc>592</xloc>
<yloc>176</yloc>
<draw>Y</draw>
</GUI>
</step>
<step>
<name>获取项目节点相关人员最新更新时间</name>
<type>TableInput</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<connection>epmet_gov_project</connection>
<sql>select
IFNULL( (SELECT UPDATED_TIME FROM project_staff ORDER BY UPDATED_TIME DESC LIMIT 1),'2000-01-01 00:00:00') START_DATE</sql>
<limit>0</limit>
<lookup/>
<execute_each_row>N</execute_each_row>
@ -795,11 +650,379 @@ IFNULL( (SELECT UPDATED_TIME FROM project_staff ORDER BY UPDATED_TIME DESC LI
<value-meta>
<type>String</type>
<storagetype>normal</storagetype>
<name>START_DATE</name>
<length>19</length>
<name>ID</name>
<length>32</length>
<precision>-1</precision>
<origin>获取项目节点相关人员最新更新时间</origin>
<comments>ID</comments>
<conversion_Mask/>
<decimal_symbol>.</decimal_symbol>
<grouping_symbol>,</grouping_symbol>
<currency_symbol/>
<trim_type>none</trim_type>
<case_insensitive>N</case_insensitive>
<collator_disabled>Y</collator_disabled>
<collator_strength>0</collator_strength>
<sort_descending>N</sort_descending>
<output_padding>N</output_padding>
<date_format_lenient>N</date_format_lenient>
<date_format_locale>zh_CN</date_format_locale>
<date_format_timezone>Asia/Shanghai</date_format_timezone>
<lenient_string_to_number>N</lenient_string_to_number>
</value-meta>
<value-meta>
<type>String</type>
<storagetype>normal</storagetype>
<name>PROJECT_ID</name>
<length>32</length>
<precision>-1</precision>
<origin>获取项目节点相关人员最新更新时间</origin>
<comments>PROJECT_ID</comments>
<conversion_Mask/>
<decimal_symbol>.</decimal_symbol>
<grouping_symbol>,</grouping_symbol>
<currency_symbol/>
<trim_type>none</trim_type>
<case_insensitive>N</case_insensitive>
<collator_disabled>Y</collator_disabled>
<collator_strength>0</collator_strength>
<sort_descending>N</sort_descending>
<output_padding>N</output_padding>
<date_format_lenient>N</date_format_lenient>
<date_format_locale>zh_CN</date_format_locale>
<date_format_timezone>Asia/Shanghai</date_format_timezone>
<lenient_string_to_number>N</lenient_string_to_number>
</value-meta>
<value-meta>
<type>String</type>
<storagetype>normal</storagetype>
<name>PROCESS_ID</name>
<length>32</length>
<precision>-1</precision>
<origin>获取项目节点相关人员最新更新时间</origin>
<comments>PROCESS_ID</comments>
<conversion_Mask/>
<decimal_symbol>.</decimal_symbol>
<grouping_symbol>,</grouping_symbol>
<currency_symbol/>
<trim_type>none</trim_type>
<case_insensitive>N</case_insensitive>
<collator_disabled>Y</collator_disabled>
<collator_strength>0</collator_strength>
<sort_descending>N</sort_descending>
<output_padding>N</output_padding>
<date_format_lenient>N</date_format_lenient>
<date_format_locale>zh_CN</date_format_locale>
<date_format_timezone>Asia/Shanghai</date_format_timezone>
<lenient_string_to_number>N</lenient_string_to_number>
</value-meta>
<value-meta>
<type>String</type>
<storagetype>normal</storagetype>
<name>CUSTOMER_ID</name>
<length>255</length>
<precision>-1</precision>
<origin>获取项目节点相关人员最新更新时间</origin>
<comments>CUSTOMER_ID</comments>
<conversion_Mask/>
<decimal_symbol>.</decimal_symbol>
<grouping_symbol>,</grouping_symbol>
<currency_symbol/>
<trim_type>none</trim_type>
<case_insensitive>N</case_insensitive>
<collator_disabled>Y</collator_disabled>
<collator_strength>0</collator_strength>
<sort_descending>N</sort_descending>
<output_padding>N</output_padding>
<date_format_lenient>N</date_format_lenient>
<date_format_locale>zh_CN</date_format_locale>
<date_format_timezone>Asia/Shanghai</date_format_timezone>
<lenient_string_to_number>N</lenient_string_to_number>
</value-meta>
<value-meta>
<type>String</type>
<storagetype>normal</storagetype>
<name>ORG_ID</name>
<length>20</length>
<precision>-1</precision>
<origin>获取项目节点相关人员最新更新时间</origin>
<comments>ORG_ID</comments>
<conversion_Mask/>
<decimal_symbol>.</decimal_symbol>
<grouping_symbol>,</grouping_symbol>
<currency_symbol/>
<trim_type>none</trim_type>
<case_insensitive>N</case_insensitive>
<collator_disabled>Y</collator_disabled>
<collator_strength>0</collator_strength>
<sort_descending>N</sort_descending>
<output_padding>N</output_padding>
<date_format_lenient>N</date_format_lenient>
<date_format_locale>zh_CN</date_format_locale>
<date_format_timezone>Asia/Shanghai</date_format_timezone>
<lenient_string_to_number>N</lenient_string_to_number>
</value-meta>
<value-meta>
<type>String</type>
<storagetype>normal</storagetype>
<name>DEPARTMENT_ID</name>
<length>20</length>
<precision>-1</precision>
<origin>获取项目节点相关人员最新更新时间</origin>
<comments>DEPARTMENT_ID</comments>
<conversion_Mask/>
<decimal_symbol>.</decimal_symbol>
<grouping_symbol>,</grouping_symbol>
<currency_symbol/>
<trim_type>none</trim_type>
<case_insensitive>N</case_insensitive>
<collator_disabled>Y</collator_disabled>
<collator_strength>0</collator_strength>
<sort_descending>N</sort_descending>
<output_padding>N</output_padding>
<date_format_lenient>N</date_format_lenient>
<date_format_locale>zh_CN</date_format_locale>
<date_format_timezone>Asia/Shanghai</date_format_timezone>
<lenient_string_to_number>N</lenient_string_to_number>
</value-meta>
<value-meta>
<type>String</type>
<storagetype>normal</storagetype>
<name>GRID_ID</name>
<length>20</length>
<precision>-1</precision>
<origin>获取项目节点相关人员最新更新时间</origin>
<comments>GRID_ID</comments>
<conversion_Mask/>
<decimal_symbol>.</decimal_symbol>
<grouping_symbol>,</grouping_symbol>
<currency_symbol/>
<trim_type>none</trim_type>
<case_insensitive>N</case_insensitive>
<collator_disabled>Y</collator_disabled>
<collator_strength>0</collator_strength>
<sort_descending>N</sort_descending>
<output_padding>N</output_padding>
<date_format_lenient>N</date_format_lenient>
<date_format_locale>zh_CN</date_format_locale>
<date_format_timezone>Asia/Shanghai</date_format_timezone>
<lenient_string_to_number>N</lenient_string_to_number>
</value-meta>
<value-meta>
<type>String</type>
<storagetype>normal</storagetype>
<name>ORG_ID_PATH</name>
<length>521</length>
<precision>-1</precision>
<origin>获取项目节点相关人员最新更新时间</origin>
<comments>ORG_ID_PATH</comments>
<conversion_Mask/>
<decimal_symbol>.</decimal_symbol>
<grouping_symbol>,</grouping_symbol>
<currency_symbol/>
<trim_type>none</trim_type>
<case_insensitive>N</case_insensitive>
<collator_disabled>Y</collator_disabled>
<collator_strength>0</collator_strength>
<sort_descending>N</sort_descending>
<output_padding>N</output_padding>
<date_format_lenient>N</date_format_lenient>
<date_format_locale>zh_CN</date_format_locale>
<date_format_timezone>Asia/Shanghai</date_format_timezone>
<lenient_string_to_number>N</lenient_string_to_number>
</value-meta>
<value-meta>
<type>String</type>
<storagetype>normal</storagetype>
<name>STAFF_ID</name>
<length>32</length>
<precision>-1</precision>
<origin>获取项目节点相关人员最新更新时间</origin>
<comments>STAFF_ID</comments>
<conversion_Mask/>
<decimal_symbol>.</decimal_symbol>
<grouping_symbol>,</grouping_symbol>
<currency_symbol/>
<trim_type>none</trim_type>
<case_insensitive>N</case_insensitive>
<collator_disabled>Y</collator_disabled>
<collator_strength>0</collator_strength>
<sort_descending>N</sort_descending>
<output_padding>N</output_padding>
<date_format_lenient>N</date_format_lenient>
<date_format_locale>zh_CN</date_format_locale>
<date_format_timezone>Asia/Shanghai</date_format_timezone>
<lenient_string_to_number>N</lenient_string_to_number>
</value-meta>
<value-meta>
<type>String</type>
<storagetype>normal</storagetype>
<name>DEPARTMENT_NAME</name>
<length>255</length>
<precision>-1</precision>
<origin>获取项目节点相关人员最新更新时间</origin>
<comments>DEPARTMENT_NAME</comments>
<conversion_Mask/>
<decimal_symbol>.</decimal_symbol>
<grouping_symbol>,</grouping_symbol>
<currency_symbol/>
<trim_type>none</trim_type>
<case_insensitive>N</case_insensitive>
<collator_disabled>Y</collator_disabled>
<collator_strength>0</collator_strength>
<sort_descending>N</sort_descending>
<output_padding>N</output_padding>
<date_format_lenient>N</date_format_lenient>
<date_format_locale>zh_CN</date_format_locale>
<date_format_timezone>Asia/Shanghai</date_format_timezone>
<lenient_string_to_number>N</lenient_string_to_number>
</value-meta>
<value-meta>
<type>String</type>
<storagetype>normal</storagetype>
<name>IS_HANDLE</name>
<length>9</length>
<precision>-1</precision>
<origin>获取项目节点相关人员最新更新时间</origin>
<comments>IS_HANDLE</comments>
<conversion_Mask/>
<decimal_symbol>.</decimal_symbol>
<grouping_symbol>,</grouping_symbol>
<currency_symbol/>
<trim_type>none</trim_type>
<case_insensitive>N</case_insensitive>
<collator_disabled>Y</collator_disabled>
<collator_strength>0</collator_strength>
<sort_descending>N</sort_descending>
<output_padding>N</output_padding>
<date_format_lenient>N</date_format_lenient>
<date_format_locale>zh_CN</date_format_locale>
<date_format_timezone>Asia/Shanghai</date_format_timezone>
<lenient_string_to_number>N</lenient_string_to_number>
</value-meta>
<value-meta>
<type>String</type>
<storagetype>normal</storagetype>
<name>DEL_FLAG</name>
<length>1</length>
<precision>-1</precision>
<origin>获取项目节点相关人员最新更新时间</origin>
<comments>DEL_FLAG</comments>
<conversion_Mask/>
<decimal_symbol>.</decimal_symbol>
<grouping_symbol>,</grouping_symbol>
<currency_symbol/>
<trim_type>none</trim_type>
<case_insensitive>N</case_insensitive>
<collator_disabled>Y</collator_disabled>
<collator_strength>0</collator_strength>
<sort_descending>N</sort_descending>
<output_padding>N</output_padding>
<date_format_lenient>N</date_format_lenient>
<date_format_locale>zh_CN</date_format_locale>
<date_format_timezone>Asia/Shanghai</date_format_timezone>
<lenient_string_to_number>N</lenient_string_to_number>
</value-meta>
<value-meta>
<type>Integer</type>
<storagetype>normal</storagetype>
<name>REVISION</name>
<length>9</length>
<precision>0</precision>
<origin>获取项目节点相关人员最新更新时间</origin>
<comments>REVISION</comments>
<conversion_Mask>####0;-####0</conversion_Mask>
<decimal_symbol>.</decimal_symbol>
<grouping_symbol>,</grouping_symbol>
<currency_symbol/>
<trim_type>none</trim_type>
<case_insensitive>N</case_insensitive>
<collator_disabled>Y</collator_disabled>
<collator_strength>0</collator_strength>
<sort_descending>N</sort_descending>
<output_padding>N</output_padding>
<date_format_lenient>N</date_format_lenient>
<date_format_locale>zh_CN</date_format_locale>
<date_format_timezone>Asia/Shanghai</date_format_timezone>
<lenient_string_to_number>N</lenient_string_to_number>
</value-meta>
<value-meta>
<type>String</type>
<storagetype>normal</storagetype>
<name>CREATED_BY</name>
<length>32</length>
<precision>-1</precision>
<origin>获取项目节点相关人员最新更新时间</origin>
<comments>CREATED_BY</comments>
<conversion_Mask/>
<decimal_symbol>.</decimal_symbol>
<grouping_symbol>,</grouping_symbol>
<currency_symbol/>
<trim_type>none</trim_type>
<case_insensitive>N</case_insensitive>
<collator_disabled>Y</collator_disabled>
<collator_strength>0</collator_strength>
<sort_descending>N</sort_descending>
<output_padding>N</output_padding>
<date_format_lenient>N</date_format_lenient>
<date_format_locale>zh_CN</date_format_locale>
<date_format_timezone>Asia/Shanghai</date_format_timezone>
<lenient_string_to_number>N</lenient_string_to_number>
</value-meta>
<value-meta>
<type>Timestamp</type>
<storagetype>normal</storagetype>
<name>CREATED_TIME</name>
<length>0</length>
<precision>-1</precision>
<origin>获取项目节点相关人员最新更新时间</origin>
<comments>CREATED_TIME</comments>
<conversion_Mask/>
<decimal_symbol>.</decimal_symbol>
<grouping_symbol>,</grouping_symbol>
<currency_symbol/>
<trim_type>none</trim_type>
<case_insensitive>N</case_insensitive>
<collator_disabled>Y</collator_disabled>
<collator_strength>0</collator_strength>
<sort_descending>N</sort_descending>
<output_padding>N</output_padding>
<date_format_lenient>N</date_format_lenient>
<date_format_locale>zh_CN</date_format_locale>
<date_format_timezone>Asia/Shanghai</date_format_timezone>
<lenient_string_to_number>N</lenient_string_to_number>
</value-meta>
<value-meta>
<type>String</type>
<storagetype>normal</storagetype>
<name>UPDATED_BY</name>
<length>32</length>
<precision>-1</precision>
<origin>获取项目节点相关人员最新更新时间</origin>
<comments>UPDATED_BY</comments>
<conversion_Mask/>
<decimal_symbol>.</decimal_symbol>
<grouping_symbol>,</grouping_symbol>
<currency_symbol/>
<trim_type>none</trim_type>
<case_insensitive>N</case_insensitive>
<collator_disabled>Y</collator_disabled>
<collator_strength>0</collator_strength>
<sort_descending>N</sort_descending>
<output_padding>N</output_padding>
<date_format_lenient>N</date_format_lenient>
<date_format_locale>zh_CN</date_format_locale>
<date_format_timezone>Asia/Shanghai</date_format_timezone>
<lenient_string_to_number>N</lenient_string_to_number>
</value-meta>
<value-meta>
<type>Timestamp</type>
<storagetype>normal</storagetype>
<name>UPDATED_TIME</name>
<length>0</length>
<precision>-1</precision>
<origin>获取项目节点相关人员最新更新时间</origin>
<comments>START_DATE</comments>
<comments>UPDATED_TIME</comments>
<conversion_Mask/>
<decimal_symbol>.</decimal_symbol>
<grouping_symbol>,</grouping_symbol>
@ -830,6 +1053,118 @@ IFNULL( (SELECT UPDATED_TIME FROM project_staff ORDER BY UPDATED_TIME DESC LI
<draw>Y</draw>
</GUI>
</step>
<step>
<name>表输出</name>
<type>TableOutput</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<connection>epmet_gov_project</connection>
<schema/>
<table>project_staff</table>
<commit>1000</commit>
<truncate>Y</truncate>
<ignore_errors>N</ignore_errors>
<use_batch>Y</use_batch>
<specify_fields>Y</specify_fields>
<partitioning_enabled>N</partitioning_enabled>
<partitioning_field/>
<partitioning_daily>N</partitioning_daily>
<partitioning_monthly>Y</partitioning_monthly>
<tablename_in_field>N</tablename_in_field>
<tablename_field/>
<tablename_in_table>Y</tablename_in_table>
<return_keys>N</return_keys>
<return_field/>
<fields>
<field>
<column_name>ID</column_name>
<stream_name>ID</stream_name>
</field>
<field>
<column_name>PROJECT_ID</column_name>
<stream_name>PROJECT_ID</stream_name>
</field>
<field>
<column_name>PROCESS_ID</column_name>
<stream_name>PROCESS_ID</stream_name>
</field>
<field>
<column_name>CUSTOMER_ID</column_name>
<stream_name>CUSTOMER_ID</stream_name>
</field>
<field>
<column_name>ORG_ID</column_name>
<stream_name>ORG_ID</stream_name>
</field>
<field>
<column_name>DEPARTMENT_ID</column_name>
<stream_name>DEPARTMENT_ID</stream_name>
</field>
<field>
<column_name>GRID_ID</column_name>
<stream_name>GRID_ID</stream_name>
</field>
<field>
<column_name>ORG_ID_PATH</column_name>
<stream_name>ORG_ID_PATH</stream_name>
</field>
<field>
<column_name>STAFF_ID</column_name>
<stream_name>STAFF_ID</stream_name>
</field>
<field>
<column_name>DEPARTMENT_NAME</column_name>
<stream_name>DEPARTMENT_NAME</stream_name>
</field>
<field>
<column_name>IS_HANDLE</column_name>
<stream_name>IS_HANDLE</stream_name>
</field>
<field>
<column_name>DEL_FLAG</column_name>
<stream_name>DEL_FLAG</stream_name>
</field>
<field>
<column_name>REVISION</column_name>
<stream_name>REVISION</stream_name>
</field>
<field>
<column_name>CREATED_BY</column_name>
<stream_name>CREATED_BY</stream_name>
</field>
<field>
<column_name>CREATED_TIME</column_name>
<stream_name>CREATED_TIME</stream_name>
</field>
<field>
<column_name>UPDATED_BY</column_name>
<stream_name>UPDATED_BY</stream_name>
</field>
<field>
<column_name>UPDATED_TIME</column_name>
<stream_name>UPDATED_TIME</stream_name>
</field>
</fields>
<attributes/>
<cluster_schema/>
<remotesteps>
<input>
</input>
<output>
</output>
</remotesteps>
<GUI>
<xloc>576</xloc>
<yloc>176</yloc>
<draw>Y</draw>
</GUI>
</step>
<step_error_handling>
</step_error_handling>
<slave-step-copy-partition-distribution>

Write Preview
Loading…
Cancel
Save