diff options
| author | stephanchrst <stephanchrst@gmail.com> | 2025-07-05 11:03:00 +0700 |
|---|---|---|
| committer | stephanchrst <stephanchrst@gmail.com> | 2025-07-05 11:03:00 +0700 |
| commit | 6e58f9c35caa3a3c01c257dcf1137ce024ccc6eb (patch) | |
| tree | 4f43bb1bc77199aaa62ae49a676798a7a8aedc55 | |
| parent | e0baab61816dcc3309ebcfb574f01b3dcee65cce (diff) | |
move materialized view to bottom sequence
| -rw-r--r-- | import_all_data_bi_indoteknik.kjb | 66 | ||||
| -rw-r--r-- | refresh_mv_job.kjb | 386 | ||||
| -rw-r--r-- | run_indoteknik_job.kjb | 48 |
3 files changed, 442 insertions, 58 deletions
diff --git a/import_all_data_bi_indoteknik.kjb b/import_all_data_bi_indoteknik.kjb index c29f010..9536ee3 100644 --- a/import_all_data_bi_indoteknik.kjb +++ b/import_all_data_bi_indoteknik.kjb @@ -1581,45 +1581,6 @@ <attributes_kjc/> </entry> <entry> - <name>refresh_materialized_view</name> - <description/> - <type>TRANS</type> - <attributes/> - <specification_method>filename</specification_method> - <trans_object_id/> - <filename>/home/stephan/transformation-job-bi/refresh_materialized_view.ktr</filename> - <transname/> - <arg_from_previous>N</arg_from_previous> - <params_from_previous>N</params_from_previous> - <exec_per_row>N</exec_per_row> - <clear_rows>N</clear_rows> - <clear_files>N</clear_files> - <set_logfile>N</set_logfile> - <logfile/> - <logext/> - <add_date>N</add_date> - <add_time>N</add_time> - <loglevel>Basic</loglevel> - <cluster>N</cluster> - <slave_server_name/> - <set_append_logfile>N</set_append_logfile> - <wait_until_finished>Y</wait_until_finished> - <follow_abort_remote>N</follow_abort_remote> - <create_parent_folder>N</create_parent_folder> - <logging_remote_work>N</logging_remote_work> - <run_configuration>Pentaho local</run_configuration> - <suppress_result_data>N</suppress_result_data> - <parameters> - <pass_all_parameters>Y</pass_all_parameters> - </parameters> - <parallel>N</parallel> - <draw>Y</draw> - <nr>0</nr> - <xloc>1088</xloc> - <yloc>528</yloc> - <attributes_kjc/> - </entry> - <entry> <name>delivery carrier</name> <description/> <type>TRANS</type> @@ -2087,24 +2048,6 @@ <unconditional>N</unconditional> </hop> <hop> - <from>delivery carrier</from> - <to>refresh_materialized_view</to> - <from_nr>0</from_nr> - <to_nr>0</to_nr> - <enabled>Y</enabled> - <evaluation>Y</evaluation> - <unconditional>N</unconditional> - </hop> - <hop> - <from>refresh_materialized_view</from> - <to>calculate_lob_category</to> - <from_nr>0</from_nr> - <to_nr>0</to_nr> - <enabled>Y</enabled> - <evaluation>Y</evaluation> - <unconditional>N</unconditional> - </hop> - <hop> <from>calculate_lob_category</from> <to>calculate_lob_category append</to> <from_nr>0</from_nr> @@ -2140,6 +2083,15 @@ <evaluation>Y</evaluation> <unconditional>N</unconditional> </hop> + <hop> + <from>delivery carrier</from> + <to>calculate_lob_category</to> + <from_nr>0</from_nr> + <to_nr>0</to_nr> + <enabled>Y</enabled> + <evaluation>Y</evaluation> + <unconditional>N</unconditional> + </hop> </hops> <notepads> </notepads> diff --git a/refresh_mv_job.kjb b/refresh_mv_job.kjb new file mode 100644 index 0000000..5edb1eb --- /dev/null +++ b/refresh_mv_job.kjb @@ -0,0 +1,386 @@ +<?xml version="1.0" encoding="UTF-8"?> +<job> + <name>refresh_mv_job</name> + <description/> + <extended_description/> + <job_version/> + <directory>/</directory> + <created_user>-</created_user> + <created_date>2025/07/05 10:56:58.530</created_date> + <modified_user>-</modified_user> + <modified_date>2025/07/05 10:56:58.530</modified_date> + <parameters> + </parameters> + <slaveservers> + </slaveservers> + <job-log-table> + <connection/> + <schema/> + <table/> + <size_limit_lines/> + <interval/> + <timeout_days/> + <field> + <id>ID_JOB</id> + <enabled>Y</enabled> + <name>ID_JOB</name> + </field> + <field> + <id>CHANNEL_ID</id> + <enabled>Y</enabled> + <name>CHANNEL_ID</name> + </field> + <field> + <id>JOBNAME</id> + <enabled>Y</enabled> + <name>JOBNAME</name> + </field> + <field> + <id>STATUS</id> + <enabled>Y</enabled> + <name>STATUS</name> + </field> + <field> + <id>LINES_READ</id> + <enabled>Y</enabled> + <name>LINES_READ</name> + </field> + <field> + <id>LINES_WRITTEN</id> + <enabled>Y</enabled> + <name>LINES_WRITTEN</name> + </field> + <field> + <id>LINES_UPDATED</id> + <enabled>Y</enabled> + <name>LINES_UPDATED</name> + </field> + <field> + <id>LINES_INPUT</id> + <enabled>Y</enabled> + <name>LINES_INPUT</name> + </field> + <field> + <id>LINES_OUTPUT</id> + <enabled>Y</enabled> + <name>LINES_OUTPUT</name> + </field> + <field> + <id>LINES_REJECTED</id> + <enabled>Y</enabled> + <name>LINES_REJECTED</name> + </field> + <field> + <id>ERRORS</id> + <enabled>Y</enabled> + <name>ERRORS</name> + </field> + <field> + <id>STARTDATE</id> + <enabled>Y</enabled> + <name>STARTDATE</name> + </field> + <field> + <id>ENDDATE</id> + <enabled>Y</enabled> + <name>ENDDATE</name> + </field> + <field> + <id>LOGDATE</id> + <enabled>Y</enabled> + <name>LOGDATE</name> + </field> + <field> + <id>DEPDATE</id> + <enabled>Y</enabled> + <name>DEPDATE</name> + </field> + <field> + <id>REPLAYDATE</id> + <enabled>Y</enabled> + <name>REPLAYDATE</name> + </field> + <field> + <id>LOG_FIELD</id> + <enabled>Y</enabled> + <name>LOG_FIELD</name> + </field> + <field> + <id>EXECUTING_SERVER</id> + <enabled>N</enabled> + <name>EXECUTING_SERVER</name> + </field> + <field> + <id>EXECUTING_USER</id> + <enabled>N</enabled> + <name>EXECUTING_USER</name> + </field> + <field> + <id>START_JOB_ENTRY</id> + <enabled>N</enabled> + <name>START_JOB_ENTRY</name> + </field> + <field> + <id>CLIENT</id> + <enabled>N</enabled> + <name>CLIENT</name> + </field> + </job-log-table> + <jobentry-log-table> + <connection/> + <schema/> + <table/> + <timeout_days/> + <field> + <id>ID_BATCH</id> + <enabled>Y</enabled> + <name>ID_BATCH</name> + </field> + <field> + <id>CHANNEL_ID</id> + <enabled>Y</enabled> + <name>CHANNEL_ID</name> + </field> + <field> + <id>LOG_DATE</id> + <enabled>Y</enabled> + <name>LOG_DATE</name> + </field> + <field> + <id>JOBNAME</id> + <enabled>Y</enabled> + <name>TRANSNAME</name> + </field> + <field> + <id>JOBENTRYNAME</id> + <enabled>Y</enabled> + <name>STEPNAME</name> + </field> + <field> + <id>LINES_READ</id> + <enabled>Y</enabled> + <name>LINES_READ</name> + </field> + <field> + <id>LINES_WRITTEN</id> + <enabled>Y</enabled> + <name>LINES_WRITTEN</name> + </field> + <field> + <id>LINES_UPDATED</id> + <enabled>Y</enabled> + <name>LINES_UPDATED</name> + </field> + <field> + <id>LINES_INPUT</id> + <enabled>Y</enabled> + <name>LINES_INPUT</name> + </field> + <field> + <id>LINES_OUTPUT</id> + <enabled>Y</enabled> + <name>LINES_OUTPUT</name> + </field> + <field> + <id>LINES_REJECTED</id> + <enabled>Y</enabled> + <name>LINES_REJECTED</name> + </field> + <field> + <id>ERRORS</id> + <enabled>Y</enabled> + <name>ERRORS</name> + </field> + <field> + <id>RESULT</id> + <enabled>Y</enabled> + <name>RESULT</name> + </field> + <field> + <id>NR_RESULT_ROWS</id> + <enabled>Y</enabled> + <name>NR_RESULT_ROWS</name> + </field> + <field> + <id>NR_RESULT_FILES</id> + <enabled>Y</enabled> + <name>NR_RESULT_FILES</name> + </field> + <field> + <id>LOG_FIELD</id> + <enabled>N</enabled> + <name>LOG_FIELD</name> + </field> + <field> + <id>COPY_NR</id> + <enabled>N</enabled> + <name>COPY_NR</name> + </field> + </jobentry-log-table> + <channel-log-table> + <connection/> + <schema/> + <table/> + <timeout_days/> + <field> + <id>ID_BATCH</id> + <enabled>Y</enabled> + <name>ID_BATCH</name> + </field> + <field> + <id>CHANNEL_ID</id> + <enabled>Y</enabled> + <name>CHANNEL_ID</name> + </field> + <field> + <id>LOG_DATE</id> + <enabled>Y</enabled> + <name>LOG_DATE</name> + </field> + <field> + <id>LOGGING_OBJECT_TYPE</id> + <enabled>Y</enabled> + <name>LOGGING_OBJECT_TYPE</name> + </field> + <field> + <id>OBJECT_NAME</id> + <enabled>Y</enabled> + <name>OBJECT_NAME</name> + </field> + <field> + <id>OBJECT_COPY</id> + <enabled>Y</enabled> + <name>OBJECT_COPY</name> + </field> + <field> + <id>REPOSITORY_DIRECTORY</id> + <enabled>Y</enabled> + <name>REPOSITORY_DIRECTORY</name> + </field> + <field> + <id>FILENAME</id> + <enabled>Y</enabled> + <name>FILENAME</name> + </field> + <field> + <id>OBJECT_ID</id> + <enabled>Y</enabled> + <name>OBJECT_ID</name> + </field> + <field> + <id>OBJECT_REVISION</id> + <enabled>Y</enabled> + <name>OBJECT_REVISION</name> + </field> + <field> + <id>PARENT_CHANNEL_ID</id> + <enabled>Y</enabled> + <name>PARENT_CHANNEL_ID</name> + </field> + <field> + <id>ROOT_CHANNEL_ID</id> + <enabled>Y</enabled> + <name>ROOT_CHANNEL_ID</name> + </field> + </channel-log-table> + <pass_batchid>N</pass_batchid> + <shared_objects_file/> + <entries> + <entry> + <name>Start</name> + <description/> + <type>SPECIAL</type> + <attributes/> + <start>Y</start> + <dummy>N</dummy> + <repeat>N</repeat> + <schedulerType>0</schedulerType> + <intervalSeconds>0</intervalSeconds> + <intervalMinutes>60</intervalMinutes> + <hour>12</hour> + <minutes>0</minutes> + <weekDay>1</weekDay> + <DayOfMonth>1</DayOfMonth> + <parallel>N</parallel> + <draw>Y</draw> + <nr>0</nr> + <xloc>176</xloc> + <yloc>112</yloc> + <attributes_kjc/> + </entry> + <entry> + <name>refresh mv ktr</name> + <description/> + <type>TRANS</type> + <attributes/> + <specification_method>filename</specification_method> + <trans_object_id/> + <filename>/home/stephan/transformation-job-bi/refresh_materialized_view.ktr</filename> + <transname/> + <arg_from_previous>N</arg_from_previous> + <params_from_previous>N</params_from_previous> + <exec_per_row>N</exec_per_row> + <clear_rows>N</clear_rows> + <clear_files>N</clear_files> + <set_logfile>N</set_logfile> + <logfile/> + <logext/> + <add_date>N</add_date> + <add_time>N</add_time> + <loglevel>Basic</loglevel> + <cluster>N</cluster> + <slave_server_name/> + <set_append_logfile>N</set_append_logfile> + <wait_until_finished>Y</wait_until_finished> + <follow_abort_remote>N</follow_abort_remote> + <create_parent_folder>N</create_parent_folder> + <logging_remote_work>N</logging_remote_work> + <run_configuration>Pentaho local</run_configuration> + <suppress_result_data>N</suppress_result_data> + <parameters> + <pass_all_parameters>Y</pass_all_parameters> + </parameters> + <parallel>N</parallel> + <draw>Y</draw> + <nr>0</nr> + <xloc>352</xloc> + <yloc>112</yloc> + <attributes_kjc/> + </entry> + <entry> + <name>Success</name> + <description/> + <type>SUCCESS</type> + <attributes/> + <parallel>N</parallel> + <draw>Y</draw> + <nr>0</nr> + <xloc>528</xloc> + <yloc>112</yloc> + <attributes_kjc/> + </entry> + </entries> + <hops> + <hop> + <from>Start</from> + <to>refresh mv ktr</to> + <from_nr>0</from_nr> + <to_nr>0</to_nr> + <enabled>Y</enabled> + <evaluation>Y</evaluation> + <unconditional>Y</unconditional> + </hop> + <hop> + <from>refresh mv ktr</from> + <to>Success</to> + <from_nr>0</from_nr> + <to_nr>0</to_nr> + <enabled>Y</enabled> + <evaluation>Y</evaluation> + <unconditional>N</unconditional> + </hop> + </hops> + <notepads> + </notepads> + <attributes/> +</job> diff --git a/run_indoteknik_job.kjb b/run_indoteknik_job.kjb index 25720c1..74a41f9 100644 --- a/run_indoteknik_job.kjb +++ b/run_indoteknik_job.kjb @@ -427,7 +427,7 @@ <parallel>N</parallel> <draw>Y</draw> <nr>0</nr> - <xloc>864</xloc> + <xloc>1008</xloc> <yloc>96</yloc> <attributes_kjc/> </entry> @@ -468,6 +468,43 @@ <yloc>96</yloc> <attributes_kjc/> </entry> + <entry> + <name>refresh mv</name> + <description/> + <type>JOB</type> + <attributes/> + <specification_method>filename</specification_method> + <job_object_id/> + <filename>/home/stephan/transformation-job-bi/refresh_mv_job.kjb</filename> + <jobname/> + <directory/> + <arg_from_previous>N</arg_from_previous> + <params_from_previous>N</params_from_previous> + <exec_per_row>N</exec_per_row> + <set_logfile>N</set_logfile> + <logfile/> + <logext/> + <add_date>N</add_date> + <add_time>N</add_time> + <loglevel>Nothing</loglevel> + <slave_server_name/> + <wait_until_finished>Y</wait_until_finished> + <follow_abort_remote>N</follow_abort_remote> + <expand_remote_job>N</expand_remote_job> + <create_parent_folder>N</create_parent_folder> + <pass_export>N</pass_export> + <run_configuration>Pentaho local</run_configuration> + <parameters> + <pass_all_parameters>Y</pass_all_parameters> + </parameters> + <set_append_logfile>N</set_append_logfile> + <parallel>N</parallel> + <draw>Y</draw> + <nr>0</nr> + <xloc>880</xloc> + <yloc>96</yloc> + <attributes_kjc/> + </entry> </entries> <hops> <hop> @@ -508,6 +545,15 @@ </hop> <hop> <from>deadstock job</from> + <to>refresh mv</to> + <from_nr>0</from_nr> + <to_nr>0</to_nr> + <enabled>Y</enabled> + <evaluation>Y</evaluation> + <unconditional>N</unconditional> + </hop> + <hop> + <from>refresh mv</from> <to>Success</to> <from_nr>0</from_nr> <to_nr>0</to_nr> |
