This is an automated email from the ASF dual-hosted git repository.
hansva pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hop.git
The following commit(s) were added to refs/heads/master by this push:
new fce6faa8f5 #2187 Add header to pipeline
new a46db4cc3a Merge pull request #2306 from hansva/master
fce6faa8f5 is described below
commit fce6faa8f5ffcb2482a29ca91d888b707c74aac4
Author: Hans Van Akelyen <[email protected]>
AuthorDate: Fri Feb 10 11:38:10 2023 +0100
#2187 Add header to pipeline
---
.../hop_server/0004-repeat_pipeline.hpl | 209 +++++++++++----------
1 file changed, 105 insertions(+), 104 deletions(-)
diff --git a/integration-tests/hop_server/0004-repeat_pipeline.hpl
b/integration-tests/hop_server/0004-repeat_pipeline.hpl
index 2df8dc5ea8..06c171bf61 100644
--- a/integration-tests/hop_server/0004-repeat_pipeline.hpl
+++ b/integration-tests/hop_server/0004-repeat_pipeline.hpl
@@ -1,7 +1,25 @@
<?xml version="1.0" encoding="UTF-8"?>
+<!--
+
+Licensed to the Apache Software Foundation (ASF) under one or more
+contributor license agreements. See the NOTICE file distributed with
+this work for additional information regarding copyright ownership.
+The ASF licenses this file to You under the Apache License, Version 2.0
+(the "License"); you may not use this file except in compliance with
+the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+
+-->
<pipeline>
<info>
- <name>repeat_pipeline</name>
+ <name>0004-repeat_pipeline</name>
<name_sync_with_filename>Y</name_sync_with_filename>
<description/>
<extended_description/>
@@ -16,8 +34,6 @@
<created_date>2022/04/11 09:14:15.582</created_date>
<modified_user>-</modified_user>
<modified_date>2022/04/11 09:14:15.582</modified_date>
- <key_for_session_key/>
- <is_key_private>N</is_key_private>
</info>
<notepads>
</notepads>
@@ -53,37 +69,6 @@
<enabled>Y</enabled>
</hop>
</order>
- <transform>
- <name>Get variables</name>
- <type>GetVariable</type>
- <description/>
- <distribute>Y</distribute>
- <custom_distribution/>
- <copies>1</copies>
- <partitioning>
- <method>none</method>
- <schema_name/>
- </partitioning>
- <fields>
- <field>
- <name>counter</name>
- <variable>${COUNTER}</variable>
- <type>Integer</type>
- <format/>
- <currency/>
- <decimal/>
- <group/>
- <length>-1</length>
- <precision>-1</precision>
- <trim_type>none</trim_type>
- </field>
- </fields>
- <attributes/>
- <GUI>
- <xloc>256</xloc>
- <yloc>144</yloc>
- </GUI>
- </transform>
<transform>
<name>Generate rows</name>
<type>RowGenerator</type>
@@ -99,8 +84,8 @@
</fields>
<interval_in_ms>5000</interval_in_ms>
<last_time_field>FiveSecondsAgo</last_time_field>
- <never_ending>N</never_ending>
<limit>1</limit>
+ <never_ending>N</never_ending>
<row_time_field>now</row_time_field>
<attributes/>
<GUI>
@@ -109,8 +94,8 @@
</GUI>
</transform>
<transform>
- <name>counter + 1</name>
- <type>Calculator</type>
+ <name>Get variables</name>
+ <type>GetVariable</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
@@ -119,40 +104,19 @@
<method>none</method>
<schema_name/>
</partitioning>
- <failIfNoFile>Y</failIfNoFile>
- <calculation>
- <calc_type>CONSTANT</calc_type>
- <conversion_mask/>
- <currency_symbol/>
- <decimal_symbol/>
- <field_a>1</field_a>
- <field_b/>
- <field_c/>
- <field_name>C_1</field_name>
- <grouping_symbol/>
- <remove>N</remove>
- <value_length>-1</value_length>
- <value_precision>-1</value_precision>
- <value_type>Integer</value_type>
- </calculation>
- <calculation>
- <calc_type>ADD</calc_type>
- <conversion_mask/>
- <currency_symbol/>
- <decimal_symbol/>
- <field_a>counter</field_a>
- <field_b>C_1</field_b>
- <field_c/>
- <field_name>new_counter</field_name>
- <grouping_symbol/>
- <remove>N</remove>
- <value_length>-1</value_length>
- <value_precision>-1</value_precision>
- <value_type>Integer</value_type>
- </calculation>
+ <fields>
+ <field>
+ <length>-1</length>
+ <name>counter</name>
+ <precision>-1</precision>
+ <trim_type>none</trim_type>
+ <type>Integer</type>
+ <variable>${COUNTER}</variable>
+ </field>
+ </fields>
<attributes/>
<GUI>
- <xloc>624</xloc>
+ <xloc>256</xloc>
<yloc>144</yloc>
</GUI>
</transform>
@@ -172,7 +136,6 @@
<field_name>new_counter</field_name>
<variable_name>COUNTER</variable_name>
<variable_type>PARENT_WORKFLOW</variable_type>
- <default_value/>
</field>
</fields>
<use_formatting>Y</use_formatting>
@@ -183,8 +146,8 @@
</GUI>
</transform>
<transform>
- <name>counter >5</name>
- <type>FilterRows</type>
+ <name>Set variables 2</name>
+ <type>SetVariable</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
@@ -193,29 +156,18 @@
<method>none</method>
<schema_name/>
</partitioning>
- <send_true_to>Set variables 2</send_true_to>
- <send_false_to>Set variables</send_false_to>
- <compare>
- <condition>
- <negated>N</negated>
- <leftvalue>new_counter</leftvalue>
- <function>></function>
- <rightvalue/>
- <value>
- <name>constant</name>
- <type>Integer</type>
- <text>5</text>
- <length>-1</length>
- <precision>0</precision>
- <isnull>N</isnull>
- <mask>####0;-####0</mask>
- </value>
- </condition>
- </compare>
+ <fields>
+ <field>
+ <field_name>new_counter</field_name>
+ <variable_name>END_LOOP</variable_name>
+ <variable_type>PARENT_WORKFLOW</variable_type>
+ </field>
+ </fields>
+ <use_formatting>Y</use_formatting>
<attributes/>
<GUI>
<xloc>800</xloc>
- <yloc>144</yloc>
+ <yloc>256</yloc>
</GUI>
</transform>
<transform>
@@ -243,8 +195,8 @@
</GUI>
</transform>
<transform>
- <name>Set variables 2</name>
- <type>SetVariable</type>
+ <name>counter + 1</name>
+ <type>Calculator</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
@@ -253,19 +205,68 @@
<method>none</method>
<schema_name/>
</partitioning>
- <fields>
- <field>
- <field_name>new_counter</field_name>
- <variable_name>END_LOOP</variable_name>
- <variable_type>PARENT_WORKFLOW</variable_type>
- <default_value/>
- </field>
- </fields>
- <use_formatting>Y</use_formatting>
+ <calculation>
+ <calc_type>CONSTANT</calc_type>
+ <field_a>1</field_a>
+ <field_name>C_1</field_name>
+ <remove>N</remove>
+ <value_length>-1</value_length>
+ <value_precision>-1</value_precision>
+ <value_type>Integer</value_type>
+ </calculation>
+ <calculation>
+ <calc_type>ADD</calc_type>
+ <field_a>counter</field_a>
+ <field_b>C_1</field_b>
+ <field_name>new_counter</field_name>
+ <remove>N</remove>
+ <value_length>-1</value_length>
+ <value_precision>-1</value_precision>
+ <value_type>Integer</value_type>
+ </calculation>
+ <failIfNoFile>Y</failIfNoFile>
+ <attributes/>
+ <GUI>
+ <xloc>624</xloc>
+ <yloc>144</yloc>
+ </GUI>
+ </transform>
+ <transform>
+ <name>counter >5</name>
+ <type>FilterRows</type>
+ <description/>
+ <distribute>Y</distribute>
+ <custom_distribution/>
+ <copies>1</copies>
+ <partitioning>
+ <method>none</method>
+ <schema_name/>
+ </partitioning>
+ <compare>
+ <condition>
+ <conditions>
+</conditions>
+ <function>></function>
+ <leftvalue>new_counter</leftvalue>
+ <negated>N</negated>
+ <operator>-</operator>
+ <value>
+ <isnull>N</isnull>
+ <length>-1</length>
+ <mask>####0;-####0</mask>
+ <name>constant</name>
+ <precision>0</precision>
+ <text>5</text>
+ <type>Integer</type>
+ </value>
+ </condition>
+ </compare>
+ <send_false_to>Set variables</send_false_to>
+ <send_true_to>Set variables 2</send_true_to>
<attributes/>
<GUI>
<xloc>800</xloc>
- <yloc>256</yloc>
+ <yloc>144</yloc>
</GUI>
</transform>
<transform_error_handling>
