micord/ervu-dashboard-etl
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Merge commit '89bb9e4ed4' into feature/SUPPORT-8925_query_optimization

Browse source 
* commit '89bb9e4ed4':
  ERVU-281
This commit is contained in:
y.kuznetsova 2025-02-21 14:08:50 +03:00
commit 625b6a2177
2 changed files with 68 additions and 25 deletions
Download patch file Download diff file Expand all files Collapse all files

68
v1_apache-hop dash mapping/job_general.hwf
View file

@ -26,7 +26,7 @@
<schedulerType>0</schedulerType>
<weekDay>1</weekDay>
<parallel>N</parallel>
<xloc>320</xloc>
<xloc>144</xloc>
<yloc>240</yloc>
<attributes_hac/>
</action>
@ -60,8 +60,8 @@
<set_logfile>N</set_logfile>
<wait_until_finished>Y</wait_until_finished>
<parallel>N</parallel>
<xloc>512</xloc>
<yloc>240</yloc>
<xloc>560</xloc>
<yloc>368</yloc>
<attributes_hac/>
</action>
<action>
@ -86,8 +86,8 @@
<set_logfile>N</set_logfile>
<wait_until_finished>Y</wait_until_finished>
<parallel>N</parallel>
<xloc>720</xloc>
<yloc>240</yloc>
<xloc>768</xloc>
<yloc>368</yloc>
<attributes_hac/>
</action>
<action>
@ -110,7 +110,7 @@
<set_logfile>N</set_logfile>
<wait_until_finished>Y</wait_until_finished>
<parallel>N</parallel>
<xloc>1088</xloc>
<xloc>336</xloc>
<yloc>240</yloc>
<attributes_hac/>
</action>
@ -134,47 +134,79 @@
<set_logfile>N</set_logfile>
<wait_until_finished>Y</wait_until_finished>
<parallel>N</parallel>
<xloc>896</xloc>
<xloc>944</xloc>
<yloc>368</yloc>
<attributes_hac/>
</action>
<action>
<name>SQL.update_last_recording_date</name>
<description/>
<type>SQL</type>
<attributes/>
<connection>ervu-dashboard</connection>
<sendOneStatement>N</sendOneStatement>
<sql>update public.last_recording_date
set last_recording_date = start_time
where entry = '1'</sql>
<sqlfilename/>
<sqlfromfile>N</sqlfromfile>
<useVariableSubstitution>N</useVariableSubstitution>
<parallel>N</parallel>
<xloc>1152</xloc>
<yloc>240</yloc>
<attributes_hac/>
</action>
</actions>
<hops>
<hop>
<from>job_pack.pub_recruitment</from>
<to>job_recruitments_all</to>
<enabled>Y</enabled>
<enabled>N</enabled>
<evaluation>Y</evaluation>
<unconditional>N</unconditional>
</hop>
<hop>
<from>Start</from>
<to>job_pack.pub_recruitment</to>
<enabled>Y</enabled>
<from>job_recruitments_all</from>
<to>job_info_recruits.hwf</to>
<enabled>N</enabled>
<evaluation>Y</evaluation>
<unconditional>Y</unconditional>
<unconditional>N</unconditional>
</hop>
<hop>
<from>job_last_recording_date</from>
<from>job_info_recruits.hwf</from>
<to>SQL.update_last_recording_date</to>
<enabled>N</enabled>
<evaluation>Y</evaluation>
<unconditional>N</unconditional>
</hop>
<hop>
<from>SQL.update_last_recording_date</from>
<to>Success</to>
<enabled>Y</enabled>
<evaluation>N</evaluation>
<unconditional>Y</unconditional>
</hop>
<hop>
<from>job_recruitments_all</from>
<to>job_info_recruits.hwf</to>
<enabled>Y</enabled>
<from>job_last_recording_date</from>
<to>job_pack.pub_recruitment</to>
<enabled>N</enabled>
<evaluation>N</evaluation>
<unconditional>Y</unconditional>
</hop>
<hop>
<from>job_info_recruits.hwf</from>
<from>Start</from>
<to>job_last_recording_date</to>
<enabled>Y</enabled>
<evaluation>N</evaluation>
<evaluation>Y</evaluation>
<unconditional>Y</unconditional>
</hop>
<hop>
<from>job_last_recording_date</from>
<to>SQL.update_last_recording_date</to>
<enabled>Y</enabled>
<evaluation>Y</evaluation>
<unconditional>N</unconditional>
</hop>
</hops>
<notepads>
</notepads>

25
v1_apache-hop dash mapping/recording_date/job_last_recording_date.hwf
View file

@ -52,8 +52,6 @@
<create_parent_folder>N</create_parent_folder>
<exec_per_row>N</exec_per_row>
<filename>${Internal.Entry.Current.Folder}/last_recording_date.hpl</filename>
<logext/>
<logfile/>
<loglevel>Basic</loglevel>
<parameters>
<pass_all_parameters>Y</pass_all_parameters>
@ -64,8 +62,8 @@
<set_logfile>N</set_logfile>
<wait_until_finished>Y</wait_until_finished>
<parallel>N</parallel>
<xloc>512</xloc>
<yloc>240</yloc>
<xloc>496</xloc>
<yloc>368</yloc>
<attributes_hac/>
</action>
<action>
@ -75,7 +73,13 @@
<attributes/>
<connection>ervu-dashboard</connection>
<sendOneStatement>N</sendOneStatement>
<sql>delete from public.last_recording_date</sql>
<sql>update public.last_recording_date
set entry = '1',
start_time = now()
</sql>
<sqlfilename/>
<sqlfromfile>N</sqlfromfile>
<useVariableSubstitution>N</useVariableSubstitution>
<parallel>N</parallel>
@ -95,12 +99,19 @@
<hop>
<from>SQL.delete</from>
<to>last_recording_date</to>
<enabled>Y</enabled>
<enabled>N</enabled>
<evaluation>N</evaluation>
<unconditional>Y</unconditional>
</hop>
<hop>
<from>last_recording_date</from>
<to>Success</to>
<enabled>N</enabled>
<evaluation>Y</evaluation>
<unconditional>N</unconditional>
</hop>
<hop>
<from>last_recording_date</from>
<from>SQL.delete</from>
<to>Success</to>
<enabled>Y</enabled>
<evaluation>Y</evaluation>