This is an automated email from the ASF dual-hosted git repository.
hansva pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/hop.git
The following commit(s) were added to refs/heads/main by this push:
new 552d079649 Apply Consistent Naming to Samples (#5907)
552d079649 is described below
commit 552d07964955f213ace4d50f23933ecddadd5700
Author: Drazen Sander <[email protected]>
AuthorDate: Sun Oct 26 10:23:01 2025 +0100
Apply Consistent Naming to Samples (#5907)
Added parallel hops for join-action sample
---
..._transactions.xlsx => file-1-transactions.xlsx} | Bin
..._transactions.xlsx => file-2-transactions.xlsx} | Bin
...read_transactions.hpl => read-transactions.hpl} | 52 ++---
...n_logs.hwf => javascript-parse-action-logs.hwf} | 38 +++-
.../join/src/main/samples/actions/join-action.hwf | 216 ++++++++++++++++-----
.../{repeat_action.hwf => repeat-action.hwf} | 66 ++++---
.../actions/{repeat_child.hpl => repeat-child.hpl} | 2 +-
..._substitution.hwf => variable-substitution.hwf} | 13 +-
..._file.properties => properties-file.properties} | 0
.../transforms/{join_rows.hpl => join-rows.hpl} | 83 +++++---
..._1_transactions.csv => file-1-transactions.csv} | 0
.../transforms/csvinput-with-schemadefinition.hpl | 25 ++-
.../src/main/samples/transforms/schema-mapping.hpl | 25 ++-
13 files changed, 364 insertions(+), 156 deletions(-)
diff --git
a/assemblies/static/src/main/resources/config/projects/samples/pipelines/input/file_1_transactions.xlsx
b/assemblies/static/src/main/resources/config/projects/samples/pipelines/input/file-1-transactions.xlsx
similarity index 100%
rename from
assemblies/static/src/main/resources/config/projects/samples/pipelines/input/file_1_transactions.xlsx
rename to
assemblies/static/src/main/resources/config/projects/samples/pipelines/input/file-1-transactions.xlsx
diff --git
a/assemblies/static/src/main/resources/config/projects/samples/pipelines/input/file_2_transactions.xlsx
b/assemblies/static/src/main/resources/config/projects/samples/pipelines/input/file-2-transactions.xlsx
similarity index 100%
rename from
assemblies/static/src/main/resources/config/projects/samples/pipelines/input/file_2_transactions.xlsx
rename to
assemblies/static/src/main/resources/config/projects/samples/pipelines/input/file-2-transactions.xlsx
diff --git
a/assemblies/static/src/main/resources/config/projects/samples/pipelines/read_transactions.hpl
b/assemblies/static/src/main/resources/config/projects/samples/pipelines/read-transactions.hpl
similarity index 94%
rename from
assemblies/static/src/main/resources/config/projects/samples/pipelines/read_transactions.hpl
rename to
assemblies/static/src/main/resources/config/projects/samples/pipelines/read-transactions.hpl
index 583adaa24a..8653e973ce 100644
---
a/assemblies/static/src/main/resources/config/projects/samples/pipelines/read_transactions.hpl
+++
b/assemblies/static/src/main/resources/config/projects/samples/pipelines/read-transactions.hpl
@@ -19,7 +19,7 @@ limitations under the License.
-->
<pipeline>
<info>
- <name>read_transactions</name>
+ <name>read-transactions</name>
<name_sync_with_filename>Y</name_sync_with_filename>
<description/>
<extended_description/>
@@ -49,13 +49,13 @@ limitations under the License.
<fontcolorred>14</fontcolorred>
<fontitalic>N</fontitalic>
<fontname>Noto Sans</fontname>
- <fontsize>10</fontsize>
+ <fontsize>11</fontsize>
<height>44</height>
<xloc>96</xloc>
<yloc>32</yloc>
<note>This pipeline splits "Headers" and "Data" , then look up Headers
to construct a JSON for each xlsx.
In the JSON doesn't matter the fields order, then extract the fields with JSON
input</note>
- <width>551</width>
+ <width>651</width>
</notepad>
</notepads>
<order>
@@ -211,19 +211,29 @@ var DATA_LINE=
</partitioning>
<fields>
<field>
+ <length>-2</length>
<name>short_filename</name>
+ <precision>-2</precision>
</field>
<field>
+ <length>-2</length>
<name>Account</name>
+ <precision>-2</precision>
</field>
<field>
+ <length>-2</length>
<name>Amount</name>
+ <precision>-2</precision>
</field>
<field>
+ <length>-2</length>
<name>Company</name>
+ <precision>-2</precision>
</field>
<field>
+ <length>-2</length>
<name>Report_Date</name>
+ <precision>-2</precision>
</field>
<select_unspecified>N</select_unspecified>
</fields>
@@ -486,24 +496,14 @@ var JSON_FILE = '[' + DATA_FILE + ']'</jsScript_script>
<method>none</method>
<schema_name/>
</partitioning>
- <accept_field/>
<accept_filenames>N</accept_filenames>
- <accept_transform_name/>
<add_to_result_filenames>Y</add_to_result_filenames>
- <bad_line_files_destination_directory/>
<bad_line_files_extension>warning</bad_line_files_extension>
- <encoding/>
<error_ignored>N</error_ignored>
- <error_line_files_destination_directory/>
<error_line_files_extension>error</error_line_files_extension>
<error_line_skipped>N</error_line_skipped>
- <extensionFieldName/>
<fields>
<field>
- <currency/>
- <decimal/>
- <format/>
- <group/>
<length>-1</length>
<name>C1</name>
<precision>-1</precision>
@@ -512,10 +512,6 @@ var JSON_FILE = '[' + DATA_FILE + ']'</jsScript_script>
<type>String</type>
</field>
<field>
- <currency/>
- <decimal/>
- <format/>
- <group/>
<length>-1</length>
<name>C2</name>
<precision>-1</precision>
@@ -524,10 +520,6 @@ var JSON_FILE = '[' + DATA_FILE + ']'</jsScript_script>
<type>String</type>
</field>
<field>
- <currency/>
- <decimal/>
- <format/>
- <group/>
<length>-1</length>
<name>C3</name>
<precision>-1</precision>
@@ -536,10 +528,6 @@ var JSON_FILE = '[' + DATA_FILE + ']'</jsScript_script>
<type>String</type>
</field>
<field>
- <currency/>
- <decimal/>
- <format/>
- <group/>
<length>-1</length>
<name>C4</name>
<precision>-1</precision>
@@ -549,33 +537,23 @@ var JSON_FILE = '[' + DATA_FILE + ']'</jsScript_script>
</field>
</fields>
<file>
- <exclude_filemask/>
<file_required>N</file_required>
- <filemask>file_.*.xlsx</filemask>
+ <filemask>file-.*.xlsx</filemask>
<include_subfolders>N</include_subfolders>
<name>${PROJECT_HOME}/pipelines/input/</name>
</file>
- <filefield/>
<header>N</header>
- <hiddenFieldName/>
- <lastModificationTimeFieldName/>
+ <ignore_fields>N</ignore_fields>
<limit>0</limit>
- <line_number_files_destination_directory/>
<line_number_files_extension>line</line_number_files_extension>
<noempty>Y</noempty>
- <pathFieldName/>
- <rootUriNameFieldName/>
- <rownumfield/>
- <sheetfield/>
<sheetrownumfield>sheet_row</sheetrownumfield>
<sheets>
</sheets>
<shortFileFieldName>short_filename</shortFileFieldName>
- <sizeFieldName/>
<spreadsheet_type>SAX_POI</spreadsheet_type>
<stoponempty>N</stoponempty>
<strict_types>N</strict_types>
- <uriNameFieldName/>
<attributes/>
<GUI>
<xloc>112</xloc>
diff --git
a/plugins/actions/eval/src/main/samples/workflows/javascript_parse_action_logs.hwf
b/plugins/actions/eval/src/main/samples/workflows/javascript-parse-action-logs.hwf
similarity index 78%
rename from
plugins/actions/eval/src/main/samples/workflows/javascript_parse_action_logs.hwf
rename to
plugins/actions/eval/src/main/samples/workflows/javascript-parse-action-logs.hwf
index c0bab45128..c105f07f6e 100644
---
a/plugins/actions/eval/src/main/samples/workflows/javascript_parse_action_logs.hwf
+++
b/plugins/actions/eval/src/main/samples/workflows/javascript-parse-action-logs.hwf
@@ -18,7 +18,7 @@ limitations under the License.
-->
<workflow>
- <name>javascript_parse_action_logs</name>
+ <name>javascript-parse-action-logs</name>
<name_sync_with_filename>Y</name_sync_with_filename>
<description/>
<extended_description/>
@@ -36,6 +36,7 @@ limitations under the License.
<type>SPECIAL</type>
<attributes/>
<DayOfMonth>1</DayOfMonth>
+ <doNotWaitOnFirstExecution>N</doNotWaitOnFirstExecution>
<hour>12</hour>
<intervalMinutes>60</intervalMinutes>
<intervalSeconds>0</intervalSeconds>
@@ -44,8 +45,8 @@ limitations under the License.
<schedulerType>0</schedulerType>
<weekDay>1</weekDay>
<parallel>N</parallel>
- <xloc>50</xloc>
- <yloc>50</yloc>
+ <xloc>64</xloc>
+ <yloc>128</yloc>
<attributes_hac/>
</action>
<action>
@@ -55,7 +56,7 @@ limitations under the License.
<attributes/>
<parallel>N</parallel>
<xloc>480</xloc>
- <yloc>48</yloc>
+ <yloc>128</yloc>
<attributes_hac/>
</action>
<action>
@@ -73,7 +74,7 @@ if(logging_text != null && logging_text != ''){
true;</script>
<parallel>N</parallel>
<xloc>272</xloc>
- <yloc>160</yloc>
+ <yloc>240</yloc>
<attributes_hac/>
</action>
<action>
@@ -89,7 +90,7 @@ logging text: ${logging_text}
<logsubject/>
<parallel>N</parallel>
<xloc>272</xloc>
- <yloc>272</yloc>
+ <yloc>352</yloc>
<attributes_hac/>
</action>
<action>
@@ -106,7 +107,7 @@ logging text: ${logging_text}
<valuetype>variable</valuetype>
<parallel>N</parallel>
<xloc>272</xloc>
- <yloc>48</yloc>
+ <yloc>128</yloc>
<attributes_hac/>
</action>
</actions>
@@ -141,6 +142,29 @@ logging text: ${logging_text}
</hop>
</hops>
<notepads>
+ <notepad>
+ <backgroundcolorblue>251</backgroundcolorblue>
+ <backgroundcolorgreen>232</backgroundcolorgreen>
+ <backgroundcolorred>201</backgroundcolorred>
+ <bordercolorblue>90</bordercolorblue>
+ <bordercolorgreen>58</bordercolorgreen>
+ <bordercolorred>14</bordercolorred>
+ <fontbold>N</fontbold>
+ <fontcolorblue>90</fontcolorblue>
+ <fontcolorgreen>58</fontcolorgreen>
+ <fontcolorred>14</fontcolorred>
+ <fontitalic>N</fontitalic>
+ <fontname>Segoe UI</fontname>
+ <fontsize>11</fontsize>
+ <height>90</height>
+ <xloc>0</xloc>
+ <yloc>0</yloc>
+ <note>Example:
+
+The script gets log text from the previous action "Simple evaluation".
+Sets "logging_text" variable ${logging_text} with default value 'no logging
text received'.</note>
+ <width>596</width>
+ </notepad>
</notepads>
<attributes/>
</workflow>
diff --git a/plugins/actions/join/src/main/samples/actions/join-action.hwf
b/plugins/actions/join/src/main/samples/actions/join-action.hwf
index 3ac5b5e7c4..dd11b1c070 100644
--- a/plugins/actions/join/src/main/samples/actions/join-action.hwf
+++ b/plugins/actions/join/src/main/samples/actions/join-action.hwf
@@ -18,7 +18,7 @@ limitations under the License.
-->
<workflow>
- <name>test-join</name>
+ <name>join-action</name>
<name_sync_with_filename>Y</name_sync_with_filename>
<description/>
<extended_description/>
@@ -36,6 +36,7 @@ limitations under the License.
<type>SPECIAL</type>
<attributes/>
<DayOfMonth>1</DayOfMonth>
+ <doNotWaitOnFirstExecution>N</doNotWaitOnFirstExecution>
<hour>12</hour>
<intervalMinutes>60</intervalMinutes>
<intervalSeconds>0</intervalSeconds>
@@ -44,8 +45,8 @@ limitations under the License.
<schedulerType>0</schedulerType>
<weekDay>1</weekDay>
<parallel>Y</parallel>
- <xloc>32</xloc>
- <yloc>160</yloc>
+ <xloc>64</xloc>
+ <yloc>240</yloc>
<attributes_hac/>
</action>
<action>
@@ -54,8 +55,8 @@ limitations under the License.
<type>JOIN</type>
<attributes/>
<parallel>N</parallel>
- <xloc>288</xloc>
- <yloc>160</yloc>
+ <xloc>704</xloc>
+ <yloc>240</yloc>
<attributes_hac/>
</action>
<action>
@@ -66,8 +67,8 @@ limitations under the License.
<maximumTimeout>1</maximumTimeout>
<scaletime>0</scaletime>
<parallel>N</parallel>
- <xloc>160</xloc>
- <yloc>64</yloc>
+ <xloc>288</xloc>
+ <yloc>144</yloc>
<attributes_hac/>
</action>
<action>
@@ -78,8 +79,8 @@ limitations under the License.
<maximumTimeout>3</maximumTimeout>
<scaletime>0</scaletime>
<parallel>N</parallel>
- <xloc>160</xloc>
- <yloc>192</yloc>
+ <xloc>288</xloc>
+ <yloc>272</yloc>
<attributes_hac/>
</action>
<action>
@@ -90,116 +91,233 @@ limitations under the License.
<maximumTimeout>2</maximumTimeout>
<scaletime>0</scaletime>
<parallel>N</parallel>
- <xloc>160</xloc>
- <yloc>128</yloc>
+ <xloc>288</xloc>
+ <yloc>208</yloc>
<attributes_hac/>
</action>
<action>
- <name>Dummy 1</name>
+ <name>Dummy 2</name>
<description/>
<type>DUMMY</type>
<attributes/>
<parallel>N</parallel>
- <xloc>416</xloc>
- <yloc>160</yloc>
+ <xloc>1024</xloc>
+ <yloc>240</yloc>
<attributes_hac/>
</action>
<action>
- <name>Dummy 2</name>
+ <name>Wait for 4 seconds</name>
<description/>
- <type>DUMMY</type>
+ <type>DELAY</type>
+ <attributes/>
+ <maximumTimeout>4</maximumTimeout>
+ <scaletime>0</scaletime>
+ <parallel>N</parallel>
+ <xloc>288</xloc>
+ <yloc>336</yloc>
+ <attributes_hac/>
+ </action>
+ <action>
+ <name>Write to log - after join</name>
+ <description/>
+ <type>WRITE_TO_LOG</type>
<attributes/>
+ <loglevel>Basic</loglevel>
+ <logmessage>
+##
+- Start after "Join"</logmessage>
+ <logsubject/>
<parallel>N</parallel>
- <xloc>544</xloc>
- <yloc>160</yloc>
+ <xloc>864</xloc>
+ <yloc>240</yloc>
<attributes_hac/>
</action>
<action>
- <name>Wait for 4 seconds</name>
+ <name>Write to log</name>
<description/>
- <type>DELAY</type>
+ <type>WRITE_TO_LOG</type>
<attributes/>
- <maximumTimeout>4</maximumTimeout>
- <scaletime>0</scaletime>
+ <loglevel>Basic</loglevel>
+ <logmessage>
+##
+Run branch 1</logmessage>
+ <logsubject/>
<parallel>N</parallel>
- <xloc>160</xloc>
- <yloc>256</yloc>
+ <xloc>512</xloc>
+ <yloc>144</yloc>
+ <attributes_hac/>
+ </action>
+ <action>
+ <name>Write to log 2</name>
+ <description/>
+ <type>WRITE_TO_LOG</type>
+ <attributes/>
+ <loglevel>Basic</loglevel>
+ <logmessage>
+##
+Run branch 2</logmessage>
+ <logsubject/>
+ <parallel>N</parallel>
+ <xloc>512</xloc>
+ <yloc>208</yloc>
+ <attributes_hac/>
+ </action>
+ <action>
+ <name>Write to log 3</name>
+ <description/>
+ <type>WRITE_TO_LOG</type>
+ <attributes/>
+ <loglevel>Basic</loglevel>
+ <logmessage>
+##
+Run branch 3</logmessage>
+ <logsubject/>
+ <parallel>N</parallel>
+ <xloc>512</xloc>
+ <yloc>272</yloc>
+ <attributes_hac/>
+ </action>
+ <action>
+ <name>Write to log 4</name>
+ <description/>
+ <type>WRITE_TO_LOG</type>
+ <attributes/>
+ <loglevel>Basic</loglevel>
+ <logmessage>
+##
+Run branch 4</logmessage>
+ <logsubject/>
+ <parallel>N</parallel>
+ <xloc>512</xloc>
+ <yloc>336</yloc>
<attributes_hac/>
</action>
</actions>
<hops>
<hop>
- <from>Start</from>
- <to>Wait for 1 seconds</to>
+ <from>Join</from>
+ <to>Write to log - after join</to>
<enabled>Y</enabled>
<evaluation>Y</evaluation>
<unconditional>Y</unconditional>
</hop>
<hop>
- <from>Wait for 2 seconds</from>
+ <from>Write to log - after join</from>
+ <to>Dummy 2</to>
+ <enabled>Y</enabled>
+ <evaluation>Y</evaluation>
+ <unconditional>N</unconditional>
+ </hop>
+ <hop>
+ <from>Wait for 1 seconds</from>
+ <to>Write to log</to>
+ <enabled>Y</enabled>
+ <evaluation>Y</evaluation>
+ <unconditional>N</unconditional>
+ </hop>
+ <hop>
+ <from>Write to log</from>
<to>Join</to>
<enabled>Y</enabled>
- <evaluation>N</evaluation>
- <unconditional>Y</unconditional>
+ <evaluation>Y</evaluation>
+ <unconditional>N</unconditional>
</hop>
<hop>
- <from>Start</from>
- <to>Wait for 2 seconds</to>
+ <from>Wait for 2 seconds</from>
+ <to>Write to log 2</to>
<enabled>Y</enabled>
<evaluation>Y</evaluation>
- <unconditional>Y</unconditional>
+ <unconditional>N</unconditional>
</hop>
<hop>
- <from>Wait for 3 seconds</from>
+ <from>Write to log 2</from>
<to>Join</to>
<enabled>Y</enabled>
- <evaluation>N</evaluation>
- <unconditional>Y</unconditional>
+ <evaluation>Y</evaluation>
+ <unconditional>N</unconditional>
</hop>
<hop>
- <from>Wait for 1 seconds</from>
+ <from>Wait for 3 seconds</from>
+ <to>Write to log 3</to>
+ <enabled>Y</enabled>
+ <evaluation>Y</evaluation>
+ <unconditional>N</unconditional>
+ </hop>
+ <hop>
+ <from>Write to log 3</from>
<to>Join</to>
<enabled>Y</enabled>
- <evaluation>N</evaluation>
- <unconditional>Y</unconditional>
+ <evaluation>Y</evaluation>
+ <unconditional>N</unconditional>
</hop>
<hop>
- <from>Join</from>
- <to>Dummy 1</to>
+ <from>Wait for 4 seconds</from>
+ <to>Write to log 4</to>
<enabled>Y</enabled>
<evaluation>Y</evaluation>
- <unconditional>Y</unconditional>
+ <unconditional>N</unconditional>
+ </hop>
+ <hop>
+ <from>Write to log 4</from>
+ <to>Join</to>
+ <enabled>Y</enabled>
+ <evaluation>Y</evaluation>
+ <unconditional>N</unconditional>
</hop>
<hop>
<from>Start</from>
- <to>Wait for 3 seconds</to>
+ <to>Wait for 1 seconds</to>
<enabled>Y</enabled>
<evaluation>Y</evaluation>
<unconditional>Y</unconditional>
</hop>
<hop>
- <from>Dummy 1</from>
- <to>Dummy 2</to>
+ <from>Start</from>
+ <to>Wait for 2 seconds</to>
<enabled>Y</enabled>
<evaluation>Y</evaluation>
<unconditional>Y</unconditional>
</hop>
<hop>
<from>Start</from>
- <to>Wait for 4 seconds</to>
+ <to>Wait for 3 seconds</to>
<enabled>Y</enabled>
<evaluation>Y</evaluation>
<unconditional>Y</unconditional>
</hop>
<hop>
- <from>Wait for 4 seconds</from>
- <to>Join</to>
- <enabled>N</enabled>
- <evaluation>N</evaluation>
+ <from>Start</from>
+ <to>Wait for 4 seconds</to>
+ <enabled>Y</enabled>
+ <evaluation>Y</evaluation>
<unconditional>Y</unconditional>
</hop>
</hops>
<notepads>
+ <notepad>
+ <backgroundcolorblue>251</backgroundcolorblue>
+ <backgroundcolorgreen>232</backgroundcolorgreen>
+ <backgroundcolorred>201</backgroundcolorred>
+ <bordercolorblue>90</bordercolorblue>
+ <bordercolorgreen>58</bordercolorgreen>
+ <bordercolorred>14</bordercolorred>
+ <fontbold>N</fontbold>
+ <fontcolorblue>90</fontcolorblue>
+ <fontcolorgreen>58</fontcolorgreen>
+ <fontcolorred>14</fontcolorred>
+ <fontitalic>N</fontitalic>
+ <fontname>Segoe UI</fontname>
+ <fontsize>11</fontsize>
+ <height>110</height>
+ <xloc>0</xloc>
+ <yloc>0</yloc>
+ <note>Example:
+
+The "Wait for" actions are executed in parallel.
+The "Join" action waits until all branches have completed execution.
+Once each branch has finished, the section "Write to log - after join" is
executed.</note>
+ <width>541</width>
+ </notepad>
</notepads>
<attributes/>
</workflow>
diff --git a/plugins/actions/repeat/src/main/samples/actions/repeat_action.hwf
b/plugins/actions/repeat/src/main/samples/actions/repeat-action.hwf
similarity index 93%
rename from plugins/actions/repeat/src/main/samples/actions/repeat_action.hwf
rename to plugins/actions/repeat/src/main/samples/actions/repeat-action.hwf
index 0d3b4b6145..e4a8da64f9 100644
--- a/plugins/actions/repeat/src/main/samples/actions/repeat_action.hwf
+++ b/plugins/actions/repeat/src/main/samples/actions/repeat-action.hwf
@@ -18,7 +18,7 @@ limitations under the License.
-->
<workflow>
- <name>repeat_action</name>
+ <name>repeat-action</name>
<name_sync_with_filename>Y</name_sync_with_filename>
<description/>
<extended_description/>
@@ -41,14 +41,15 @@ limitations under the License.
<description/>
<type>SPECIAL</type>
<attributes/>
- <repeat>N</repeat>
- <schedulerType>0</schedulerType>
- <intervalSeconds>0</intervalSeconds>
- <intervalMinutes>60</intervalMinutes>
+ <DayOfMonth>1</DayOfMonth>
+ <doNotWaitOnFirstExecution>N</doNotWaitOnFirstExecution>
<hour>12</hour>
+ <intervalMinutes>60</intervalMinutes>
+ <intervalSeconds>0</intervalSeconds>
<minutes>0</minutes>
+ <repeat>N</repeat>
+ <schedulerType>0</schedulerType>
<weekDay>1</weekDay>
- <DayOfMonth>1</DayOfMonth>
<parallel>N</parallel>
<xloc>48</xloc>
<yloc>160</yloc>
@@ -59,21 +60,22 @@ limitations under the License.
<description/>
<type>Repeat</type>
<attributes/>
- <filename>${PROJECT_HOME}/actions/repeat_child.hpl</filename>
- <run_configuration>local</run_configuration>
- <variable_name>END_LOOP</variable_name>
- <variable_value/>
<delay/>
+ <filename>${PROJECT_HOME}/actions/repeat-child.hpl</filename>
<keep_values>N</keep_values>
- <logfile_enabled>N</logfile_enabled>
+ <logfile_add_date>Y</logfile_add_date>
+ <logfile_add_repetition>N</logfile_add_repetition>
+ <logfile_add_time>N</logfile_add_time>
<logfile_appended>Y</logfile_appended>
<logfile_base/>
+ <logfile_enabled>N</logfile_enabled>
<logfile_extension>log</logfile_extension>
- <logfile_add_date>Y</logfile_add_date>
- <logfile_add_time>N</logfile_add_time>
- <logfile_add_repetition>N</logfile_add_repetition>
<logfile_update_interval>5000</logfile_update_interval>
- <parameters/>
+ <parameters>
+</parameters>
+ <run_configuration>local</run_configuration>
+ <variable_name>END_LOOP</variable_name>
+ <variable_value/>
<parallel>N</parallel>
<xloc>176</xloc>
<yloc>160</yloc>
@@ -91,26 +93,26 @@ limitations under the License.
</hops>
<notepads>
<notepad>
+ <backgroundcolorblue>251</backgroundcolorblue>
+ <backgroundcolorgreen>232</backgroundcolorgreen>
+ <backgroundcolorred>201</backgroundcolorred>
+ <bordercolorblue>90</bordercolorblue>
+ <bordercolorgreen>58</bordercolorgreen>
+ <bordercolorred>14</bordercolorred>
+ <fontbold>N</fontbold>
+ <fontcolorblue>90</fontcolorblue>
+ <fontcolorgreen>58</fontcolorgreen>
+ <fontcolorred>14</fontcolorred>
+ <fontitalic>N</fontitalic>
+ <fontname>.AppleSystemUIFont</fontname>
+ <fontsize>13</fontsize>
+ <height>67</height>
+ <xloc>64</xloc>
+ <yloc>48</yloc>
<note>This action will repeat a pipeline until a condition is met.
It will increment the counter parameter until value 5 has been reached.
Then it will set the END_LOOP variable causing the repeat action to stop</note>
- <xloc>64</xloc>
- <yloc>48</yloc>
- <width>447</width>
- <heigth>58</heigth>
- <fontname>.AppleSystemUIFont</fontname>
- <fontsize>13</fontsize>
- <fontbold>N</fontbold>
- <fontitalic>N</fontitalic>
- <fontcolorred>14</fontcolorred>
- <fontcolorgreen>58</fontcolorgreen>
- <fontcolorblue>90</fontcolorblue>
- <backgroundcolorred>201</backgroundcolorred>
- <backgroundcolorgreen>232</backgroundcolorgreen>
- <backgroundcolorblue>251</backgroundcolorblue>
- <bordercolorred>14</bordercolorred>
- <bordercolorgreen>58</bordercolorgreen>
- <bordercolorblue>90</bordercolorblue>
+ <width>534</width>
</notepad>
</notepads>
<attributes/>
diff --git a/plugins/actions/repeat/src/main/samples/actions/repeat_child.hpl
b/plugins/actions/repeat/src/main/samples/actions/repeat-child.hpl
similarity index 99%
rename from plugins/actions/repeat/src/main/samples/actions/repeat_child.hpl
rename to plugins/actions/repeat/src/main/samples/actions/repeat-child.hpl
index 0c340bd40c..f0d5aa6db6 100644
--- a/plugins/actions/repeat/src/main/samples/actions/repeat_child.hpl
+++ b/plugins/actions/repeat/src/main/samples/actions/repeat-child.hpl
@@ -19,7 +19,7 @@ limitations under the License.
-->
<pipeline>
<info>
- <name>repeat_child</name>
+ <name>repeat-child</name>
<name_sync_with_filename>Y</name_sync_with_filename>
<description/>
<extended_description/>
diff --git
a/plugins/actions/setvariables/src/main/samples/actions/variable_substitution.hwf
b/plugins/actions/setvariables/src/main/samples/actions/variable-substitution.hwf
similarity index 94%
rename from
plugins/actions/setvariables/src/main/samples/actions/variable_substitution.hwf
rename to
plugins/actions/setvariables/src/main/samples/actions/variable-substitution.hwf
index 46d48aa60c..24eba37655 100644
---
a/plugins/actions/setvariables/src/main/samples/actions/variable_substitution.hwf
+++
b/plugins/actions/setvariables/src/main/samples/actions/variable-substitution.hwf
@@ -18,7 +18,7 @@ limitations under the License.
-->
<workflow>
- <name>variable_substitution</name>
+ <name>variable-substitution</name>
<name_sync_with_filename>Y</name_sync_with_filename>
<description/>
<extended_description/>
@@ -42,6 +42,7 @@ limitations under the License.
<type>SPECIAL</type>
<attributes/>
<DayOfMonth>1</DayOfMonth>
+ <doNotWaitOnFirstExecution>N</doNotWaitOnFirstExecution>
<hour>12</hour>
<intervalMinutes>60</intervalMinutes>
<intervalSeconds>0</intervalSeconds>
@@ -67,7 +68,7 @@ limitations under the License.
</field>
</fields>
<file_variable_type>CURRENT_WORKFLOW</file_variable_type>
- <filename>${PROJECT_HOME}/files/properties_file.properties</filename>
+ <filename>${PROJECT_HOME}/files/properties-file.properties</filename>
<replacevars>Y</replacevars>
<parallel>N</parallel>
<xloc>336</xloc>
@@ -132,15 +133,15 @@ param_value = ${param_value}</logmessage>
<fontcolorred>14</fontcolorred>
<fontitalic>N</fontitalic>
<fontname>Segoe UI</fontname>
- <fontsize>9</fontsize>
- <height>74</height>
+ <fontsize>11</fontsize>
+ <height>90</height>
<xloc>48</xloc>
- <yloc>48</yloc>
+ <yloc>16</yloc>
<note>The Workflow takes a parameter named parameter_value with a
default value set to "param_value".
Using the "Variable substitution" option in the "Set Variables" step enables
you to dynamically create a new variable.
This new variable is named based on the value of the content of the
parameter_value variable,
and its value can be set using other variables.</note>
- <width>621</width>
+ <width>782</width>
</notepad>
</notepads>
<attributes/>
diff --git
a/plugins/actions/setvariables/src/main/samples/files/properties_file.properties
b/plugins/actions/setvariables/src/main/samples/files/properties-file.properties
similarity index 100%
rename from
plugins/actions/setvariables/src/main/samples/files/properties_file.properties
rename to
plugins/actions/setvariables/src/main/samples/files/properties-file.properties
diff --git
a/plugins/transforms/joinrows/src/main/samples/transforms/join_rows.hpl
b/plugins/transforms/joinrows/src/main/samples/transforms/join-rows.hpl
similarity index 77%
rename from
plugins/transforms/joinrows/src/main/samples/transforms/join_rows.hpl
rename to plugins/transforms/joinrows/src/main/samples/transforms/join-rows.hpl
index 31109e729c..d3491b4032 100644
--- a/plugins/transforms/joinrows/src/main/samples/transforms/join_rows.hpl
+++ b/plugins/transforms/joinrows/src/main/samples/transforms/join-rows.hpl
@@ -19,7 +19,7 @@ limitations under the License.
-->
<pipeline>
<info>
- <name>join_rows</name>
+ <name>join-rows</name>
<name_sync_with_filename>Y</name_sync_with_filename>
<description/>
<extended_description/>
@@ -36,6 +36,48 @@ limitations under the License.
<modified_date>2025/01/30 11:17:29.800</modified_date>
</info>
<notepads>
+ <notepad>
+ <backgroundcolorblue>251</backgroundcolorblue>
+ <backgroundcolorgreen>232</backgroundcolorgreen>
+ <backgroundcolorred>201</backgroundcolorred>
+ <bordercolorblue>90</bordercolorblue>
+ <bordercolorgreen>58</bordercolorgreen>
+ <bordercolorred>14</bordercolorred>
+ <fontbold>N</fontbold>
+ <fontcolorblue>90</fontcolorblue>
+ <fontcolorgreen>58</fontcolorgreen>
+ <fontcolorred>14</fontcolorred>
+ <fontitalic>N</fontitalic>
+ <fontname>Segoe UI</fontname>
+ <fontsize>11</fontsize>
+ <height>50</height>
+ <xloc>176</xloc>
+ <yloc>16</yloc>
+ <note>Example 1:
+"Generates the Cartesian product of the values a, b, c with a, b, c."</note>
+ <width>441</width>
+ </notepad>
+ <notepad>
+ <backgroundcolorblue>251</backgroundcolorblue>
+ <backgroundcolorgreen>232</backgroundcolorgreen>
+ <backgroundcolorred>201</backgroundcolorred>
+ <bordercolorblue>90</bordercolorblue>
+ <bordercolorgreen>58</bordercolorgreen>
+ <bordercolorred>14</bordercolorred>
+ <fontbold>N</fontbold>
+ <fontcolorblue>90</fontcolorblue>
+ <fontcolorgreen>58</fontcolorgreen>
+ <fontcolorred>14</fontcolorred>
+ <fontitalic>N</fontitalic>
+ <fontname>Segoe UI</fontname>
+ <fontsize>11</fontsize>
+ <height>50</height>
+ <xloc>192</xloc>
+ <yloc>352</yloc>
+ <note>Example 2:
+"Generates the Cartesian product of the values a, b, c with a, b, c, applying
the condition field1 = field2 and field1 = a."</note>
+ <width>793</width>
+ </notepad>
</notepads>
<order>
<hop>
@@ -86,12 +128,12 @@ limitations under the License.
<length>-1</length>
<precision>-1</precision>
<set_empty_string>N</set_empty_string>
- <name>fiedl1</name>
+ <name>field1</name>
</field>
</fields>
<attributes/>
<GUI>
- <xloc>240</xloc>
+ <xloc>224</xloc>
<yloc>112</yloc>
</GUI>
</transform>
@@ -128,8 +170,8 @@ limitations under the License.
</fields>
<attributes/>
<GUI>
- <xloc>240</xloc>
- <yloc>272</yloc>
+ <xloc>224</xloc>
+ <yloc>240</yloc>
</GUI>
</transform>
<transform>
@@ -165,8 +207,8 @@ limitations under the License.
</fields>
<attributes/>
<GUI>
- <xloc>256</xloc>
- <yloc>592</yloc>
+ <xloc>224</xloc>
+ <yloc>608</yloc>
</GUI>
</transform>
<transform>
@@ -196,13 +238,13 @@ limitations under the License.
<length>-1</length>
<precision>-1</precision>
<set_empty_string>N</set_empty_string>
- <name>fiedl1</name>
+ <name>field1</name>
</field>
</fields>
<attributes/>
<GUI>
- <xloc>256</xloc>
- <yloc>432</yloc>
+ <xloc>224</xloc>
+ <yloc>448</yloc>
</GUI>
</transform>
<transform>
@@ -216,10 +258,7 @@ limitations under the License.
<method>none</method>
<schema_name/>
</partitioning>
- <directory>%%java.io.tmpdir%%</directory>
- <prefix>out</prefix>
<cache_size>500</cache_size>
- <main/>
<compare>
<condition>
<conditions>
@@ -229,10 +268,12 @@ limitations under the License.
<operator>-</operator>
</condition>
</compare>
+ <directory>%%java.io.tmpdir%%</directory>
+ <prefix>out</prefix>
<attributes/>
<GUI>
<xloc>480</xloc>
- <yloc>224</yloc>
+ <yloc>176</yloc>
</GUI>
</transform>
<transform>
@@ -246,10 +287,7 @@ limitations under the License.
<method>none</method>
<schema_name/>
</partitioning>
- <directory>%%java.io.tmpdir%%</directory>
- <prefix>out</prefix>
<cache_size>500</cache_size>
- <main/>
<compare>
<condition>
<conditions>
@@ -257,7 +295,7 @@ limitations under the License.
<conditions>
</conditions>
<function>=</function>
- <leftvalue>fiedl1</leftvalue>
+ <leftvalue>field1</leftvalue>
<negated>N</negated>
<operator>-</operator>
<rightvalue>field2</rightvalue>
@@ -266,13 +304,12 @@ limitations under the License.
<conditions>
</conditions>
<function>=</function>
- <leftvalue>fiedl1</leftvalue>
+ <leftvalue>field1</leftvalue>
<negated>N</negated>
<operator>AND</operator>
<value>
<isnull>N</isnull>
<length>-1</length>
- <mask/>
<name>constant</name>
<precision>-1</precision>
<text>a</text>
@@ -287,10 +324,12 @@ limitations under the License.
<rightvalue>field2</rightvalue>
</condition>
</compare>
+ <directory>%%java.io.tmpdir%%</directory>
+ <prefix>out</prefix>
<attributes/>
<GUI>
- <xloc>496</xloc>
- <yloc>544</yloc>
+ <xloc>448</xloc>
+ <yloc>528</yloc>
</GUI>
</transform>
<transform_error_handling>
diff --git
a/plugins/transforms/schemamapping/src/main/samples/files/file_1_transactions.csv
b/plugins/transforms/schemamapping/src/main/samples/files/file-1-transactions.csv
similarity index 100%
rename from
plugins/transforms/schemamapping/src/main/samples/files/file_1_transactions.csv
rename to
plugins/transforms/schemamapping/src/main/samples/files/file-1-transactions.csv
diff --git
a/plugins/transforms/schemamapping/src/main/samples/transforms/csvinput-with-schemadefinition.hpl
b/plugins/transforms/schemamapping/src/main/samples/transforms/csvinput-with-schemadefinition.hpl
index 6cfc26a4e7..4c77475c12 100644
---
a/plugins/transforms/schemamapping/src/main/samples/transforms/csvinput-with-schemadefinition.hpl
+++
b/plugins/transforms/schemamapping/src/main/samples/transforms/csvinput-with-schemadefinition.hpl
@@ -36,6 +36,28 @@ limitations under the License.
<modified_date>2021/07/18 11:46:17.892</modified_date>
</info>
<notepads>
+ <notepad>
+ <backgroundcolorblue>251</backgroundcolorblue>
+ <backgroundcolorgreen>232</backgroundcolorgreen>
+ <backgroundcolorred>201</backgroundcolorred>
+ <bordercolorblue>90</bordercolorblue>
+ <bordercolorgreen>58</bordercolorgreen>
+ <bordercolorred>14</bordercolorred>
+ <fontbold>N</fontbold>
+ <fontcolorblue>90</fontcolorblue>
+ <fontcolorgreen>58</fontcolorgreen>
+ <fontcolorred>14</fontcolorred>
+ <fontitalic>N</fontitalic>
+ <fontname>Segoe UI</fontname>
+ <fontsize>11</fontsize>
+ <height>70</height>
+ <xloc>96</xloc>
+ <yloc>16</yloc>
+ <note>Loads a CSV file and adapts its columns to match the structure
+defined in the schema 'Test Schema', referencing the
+metadata in 'Static Schema Definition'.</note>
+ <width>426</width>
+ </notepad>
</notepads>
<order>
<hop>
@@ -72,7 +94,7 @@ limitations under the License.
<method>none</method>
<schema_name/>
</partitioning>
- <filename>${PROJECT_HOME}/files/file_1_transactions.csv</filename>
+ <filename>${PROJECT_HOME}/files/file-1-transactions.csv</filename>
<filename_field/>
<rownum_field>row_number</rownum_field>
<include_filename>N</include_filename>
@@ -81,6 +103,7 @@ limitations under the License.
<header>Y</header>
<buffer_size>50000</buffer_size>
<schemaDefinition>Test Schema</schemaDefinition>
+ <ignoreFields>N</ignoreFields>
<lazy_conversion>N</lazy_conversion>
<add_filename_result>Y</add_filename_result>
<parallel>N</parallel>
diff --git
a/plugins/transforms/schemamapping/src/main/samples/transforms/schema-mapping.hpl
b/plugins/transforms/schemamapping/src/main/samples/transforms/schema-mapping.hpl
index 8eafc06a78..cbcc9b0a56 100644
---
a/plugins/transforms/schemamapping/src/main/samples/transforms/schema-mapping.hpl
+++
b/plugins/transforms/schemamapping/src/main/samples/transforms/schema-mapping.hpl
@@ -36,6 +36,28 @@ limitations under the License.
<modified_date>2024/02/16 18:30:47.103</modified_date>
</info>
<notepads>
+ <notepad>
+ <backgroundcolorblue>251</backgroundcolorblue>
+ <backgroundcolorgreen>232</backgroundcolorgreen>
+ <backgroundcolorred>201</backgroundcolorred>
+ <bordercolorblue>90</bordercolorblue>
+ <bordercolorgreen>58</bordercolorgreen>
+ <bordercolorred>14</bordercolorred>
+ <fontbold>N</fontbold>
+ <fontcolorblue>90</fontcolorblue>
+ <fontcolorgreen>58</fontcolorgreen>
+ <fontcolorred>14</fontcolorred>
+ <fontitalic>N</fontitalic>
+ <fontname>Segoe UI</fontname>
+ <fontsize>11</fontsize>
+ <height>70</height>
+ <xloc>320</xloc>
+ <yloc>128</yloc>
+ <note>Mapps columns to match the structure
+defined in the schema 'Test Schema', referencing the
+metadata in 'Static Schema Definition'.</note>
+ <width>360</width>
+ </notepad>
</notepads>
<order>
<hop>
@@ -60,7 +82,7 @@ limitations under the License.
<method>none</method>
<schema_name/>
</partitioning>
- <filename>${PROJECT_HOME}/files/file_1_transactions.csv</filename>
+ <filename>${PROJECT_HOME}/files/file-1-transactions.csv</filename>
<filename_field/>
<rownum_field/>
<include_filename>N</include_filename>
@@ -69,6 +91,7 @@ limitations under the License.
<header>Y</header>
<buffer_size>50000</buffer_size>
<schemaDefinition/>
+ <ignoreFields>N</ignoreFields>
<lazy_conversion>Y</lazy_conversion>
<add_filename_result>N</add_filename_result>
<parallel>N</parallel>
