Skip to content

K
kettle_yuejuan_new
Commit 6a60138b by zsy
Options

zsy

parent 1d14496b
Showing with 36 additions and 36 deletions
monitor_intelligent/union_yuejuan_monitor/transfer/total_control/gp_time/set_variable_start_time.ktr
...@@ -428,7 +428,7 @@ ...@@ -428,7 +428,7 @@
<created_user>admin</created_user> <created_user>admin</created_user>
<created_date>2021/03/03 10:49:15.361</created_date> <created_date>2021/03/03 10:49:15.361</created_date>
<modified_user>admin</modified_user> <modified_user>admin</modified_user>
<modified_date>2021/03/12 15:14:09.696</modified_date> <modified_date>2021/03/12 15:31:39.192</modified_date>
<key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key> <key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key>
<is_key_private>N</is_key_private> <is_key_private>N</is_key_private>
</info> </info>
...@@ -498,8 +498,8 @@ ...@@ -498,8 +498,8 @@
</hop> </hop>
</order> </order>
<step> <step>
<name>Table input</name> <name>Set Variables</name>
<type>TableInput</type> <type>SetVariable</type>
<description/> <description/>
<distribute>Y</distribute> <distribute>Y</distribute>
<custom_distribution/> <custom_distribution/>
...@@ -508,19 +508,21 @@ ...@@ -508,19 +508,21 @@
<method>none</method> <method>none</method>
<schema_name/> <schema_name/>
</partitioning> </partitioning>
<connection>intelligent_monitor_greenplum_neiwang</connection> <fields>
<sql>select <field>
(case when (select count(id) from union_yuejuan_source_process.gp_time_interval where status=1)>0 <field_name>start_time</field_name>
then (select max(end_time)-interval '4 s' from union_yuejuan_source_process.gp_time_interval where status=1) <variable_name>start_time</variable_name>
else '2000-01-01 00:00:00' end) as start_time, <variable_type>ROOT_JOB</variable_type>
(case when (select count(id) from union_yuejuan_source_process.gp_time_interval where status=1)>0 <default_value/>
then (select max(end_time)-interval '4 s' from union_yuejuan_source_process.gp_time_interval where status=1) </field>
else '2000-01-01 00:00:00' end) as start_time_date</sql> <field>
<limit>0</limit> <field_name>start_time_date</field_name>
<lookup/> <variable_name>start_time_date</variable_name>
<execute_each_row>N</execute_each_row> <variable_type>ROOT_JOB</variable_type>
<variables_active>N</variables_active> <default_value/>
<lazy_conversion_active>N</lazy_conversion_active> </field>
</fields>
<use_formatting>Y</use_formatting>
<attributes/> <attributes/>
<cluster_schema/> <cluster_schema/>
<remotesteps> <remotesteps>
...@@ -530,14 +532,14 @@ else '2000-01-01 00:00:00' end) as start_time_date</sql> ...@@ -530,14 +532,14 @@ else '2000-01-01 00:00:00' end) as start_time_date</sql>
</output> </output>
</remotesteps> </remotesteps>
<GUI> <GUI>
<xloc>176</xloc> <xloc>480</xloc>
<yloc>160</yloc> <yloc>160</yloc>
<draw>Y</draw> <draw>Y</draw>
</GUI> </GUI>
</step> </step>
<step> <step>
<name>Set Variables</name> <name>Table input</name>
<type>SetVariable</type> <type>TableInput</type>
<description/> <description/>
<distribute>Y</distribute> <distribute>Y</distribute>
<custom_distribution/> <custom_distribution/>
...@@ -546,21 +548,19 @@ else '2000-01-01 00:00:00' end) as start_time_date</sql> ...@@ -546,21 +548,19 @@ else '2000-01-01 00:00:00' end) as start_time_date</sql>
<method>none</method> <method>none</method>
<schema_name/> <schema_name/>
</partitioning> </partitioning>
<fields> <connection>intelligent_monitor_greenplum_neiwang</connection>
<field> <sql>select
<field_name>start_time</field_name> (case when (select count(id) from union_yuejuan_source_process.gp_time_interval where status=1)>0
<variable_name>start_time</variable_name> then (select max(end_time)-interval '4 s' from union_yuejuan_source_process.gp_time_interval where status=1)
<variable_type>ROOT_JOB</variable_type> else '2000-01-01 00:00:00' end) as start_time,
<default_value/> (case when (select count(id) from union_yuejuan_source_process.gp_time_interval where status=1)>0
</field> then (select max(end_time)-interval '4 s' from union_yuejuan_source_process.gp_time_interval where status=1)
<field> else '2000-01-01 00:00:00' end) as start_time_date</sql>
<field_name>start_time_date</field_name> <limit>0</limit>
<variable_name>start_time_date</variable_name> <lookup/>
<variable_type>ROOT_JOB</variable_type> <execute_each_row>N</execute_each_row>
<default_value/> <variables_active>N</variables_active>
</field> <lazy_conversion_active>N</lazy_conversion_active>
</fields>
<use_formatting>Y</use_formatting>
<attributes/> <attributes/>
<cluster_schema/> <cluster_schema/>
<remotesteps> <remotesteps>
...@@ -570,7 +570,7 @@ else '2000-01-01 00:00:00' end) as start_time_date</sql> ...@@ -570,7 +570,7 @@ else '2000-01-01 00:00:00' end) as start_time_date</sql>
</output> </output>
</remotesteps> </remotesteps>
<GUI> <GUI>
<xloc>480</xloc> <xloc>176</xloc>
<yloc>160</yloc> <yloc>160</yloc>
<draw>Y</draw> <draw>Y</draw>
</GUI> </GUI>
...@@ -619,7 +619,7 @@ else '2000-01-01 00:00:00' end) as start_time_date</sql> ...@@ -619,7 +619,7 @@ else '2000-01-01 00:00:00' end) as start_time_date</sql>
<type>Date</type> <type>Date</type>
<length>6</length> <length>6</length>
<precision>-2</precision> <precision>-2</precision>
<conversion_mask/> <conversion_mask>yyyy-MM-dd</conversion_mask>
<date_format_lenient>false</date_format_lenient> <date_format_lenient>false</date_format_lenient>
<date_format_locale/> <date_format_locale/>
<date_format_timezone/> <date_format_timezone/>
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment