blob: c16418771f02054ac980b758226fc8b3368b1415 [file] [log] [blame]
<?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>0019-memory-group-by-parent</name>
<name_sync_with_filename>Y</name_sync_with_filename>
<description/>
<extended_description/>
<pipeline_version/>
<pipeline_type>Normal</pipeline_type>
<parameters>
</parameters>
<capture_transform_performance>N</capture_transform_performance>
<transform_performance_capturing_delay>1000</transform_performance_capturing_delay>
<transform_performance_capturing_size_limit>100</transform_performance_capturing_size_limit>
<created_user>-</created_user>
<created_date>2022/11/15 22:16:07.801</created_date>
<modified_user>-</modified_user>
<modified_date>2022/11/15 22:16:07.801</modified_date>
<key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key>
<is_key_private>N</is_key_private>
</info>
<notepads>
</notepads>
<order>
<hop>
<from>a</from>
<to>X</to>
<enabled>Y</enabled>
</hop>
<hop>
<from>b</from>
<to>X</to>
<enabled>Y</enabled>
</hop>
<hop>
<from>c</from>
<to>X</to>
<enabled>Y</enabled>
</hop>
<hop>
<from>X</from>
<to>ETL metadata injection</to>
<enabled>Y</enabled>
</hop>
<hop>
<from>groups</from>
<to>ETL metadata injection</to>
<enabled>Y</enabled>
</hop>
<hop>
<from>aggregates</from>
<to>ETL metadata injection</to>
<enabled>Y</enabled>
</hop>
<hop>
<from>ETL metadata injection</from>
<to>Output</to>
<enabled>Y</enabled>
</hop>
</order>
<transform>
<name>ETL metadata injection</name>
<type>MetaInject</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<filename>${PROJECT_HOME}/0019-memory-group-by-child.hpl</filename>
<run_configuration>local</run_configuration>
<source_transform>Output</source_transform>
<source_output_fields>
<source_output_field>
<source_output_field_name>a</source_output_field_name>
<source_output_field_type>String</source_output_field_type>
<source_output_field_length>-1</source_output_field_length>
<source_output_field_precision>-1</source_output_field_precision>
</source_output_field>
<source_output_field>
<source_output_field_name>minB</source_output_field_name>
<source_output_field_type>String</source_output_field_type>
<source_output_field_length>-1</source_output_field_length>
<source_output_field_precision>-1</source_output_field_precision>
</source_output_field>
<source_output_field>
<source_output_field_name>maxC</source_output_field_name>
<source_output_field_type>String</source_output_field_type>
<source_output_field_length>-1</source_output_field_length>
<source_output_field_precision>-1</source_output_field_precision>
</source_output_field>
</source_output_fields>
<target_file>/tmp/mgb.hpl</target_file>
<create_parent_folder>Y</create_parent_folder>
<no_execution>N</no_execution>
<stream_source_transform>X</stream_source_transform>
<stream_target_transform>Input</stream_target_transform>
<mappings>
<mapping>
<target_transform_name>Memory group by</target_transform_name>
<target_attribute_key>AGGREGATEFIELD</target_attribute_key>
<target_detail>Y</target_detail>
<source_transform>aggregates</source_transform>
<source_field>aggField</source_field>
</mapping>
<mapping>
<target_transform_name>Memory group by</target_transform_name>
<target_attribute_key>SUBJECTFIELD</target_attribute_key>
<target_detail>Y</target_detail>
<source_transform>aggregates</source_transform>
<source_field>aggSubject</source_field>
</mapping>
<mapping>
<target_transform_name>Memory group by</target_transform_name>
<target_attribute_key>AGGREGATETYPE</target_attribute_key>
<target_detail>Y</target_detail>
<source_transform>aggregates</source_transform>
<source_field>aggType</source_field>
</mapping>
<mapping>
<target_transform_name>Memory group by</target_transform_name>
<target_attribute_key>VALUEFIELD</target_attribute_key>
<target_detail>Y</target_detail>
<source_transform>aggregates</source_transform>
<source_field>aggValue</source_field>
</mapping>
<mapping>
<target_transform_name>Memory group by</target_transform_name>
<target_attribute_key>GROUPFIELD</target_attribute_key>
<target_detail>Y</target_detail>
<source_transform>groups</source_transform>
<source_field>group</source_field>
</mapping>
</mappings>
<attributes/>
<GUI>
<xloc>368</xloc>
<yloc>176</yloc>
</GUI>
</transform>
<transform>
<name>Output</name>
<type>Dummy</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<attributes/>
<GUI>
<xloc>560</xloc>
<yloc>176</yloc>
</GUI>
</transform>
<transform>
<name>X</name>
<type>JoinRows</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<directory>${java.io.tmpdir}</directory>
<prefix>out</prefix>
<cache_size>500</cache_size>
<main/>
<compare>
<condition>
<negated>N</negated>
<leftvalue/>
<function>=</function>
<rightvalue/>
</condition>
</compare>
<attributes/>
<GUI>
<xloc>240</xloc>
<yloc>176</yloc>
</GUI>
</transform>
<transform>
<name>a</name>
<type>DataGrid</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<fields>
<field>
<set_empty_string>N</set_empty_string>
<length>-1</length>
<name>a</name>
<precision>-1</precision>
<type>String</type>
</field>
</fields>
<data>
<line>
<item>a1</item>
</line>
<line>
<item>a2</item>
</line>
<line>
<item>a3</item>
</line>
<line>
<item>a4</item>
</line>
</data>
<attributes/>
<GUI>
<xloc>112</xloc>
<yloc>96</yloc>
</GUI>
</transform>
<transform>
<name>aggregates</name>
<type>DataGrid</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<fields>
<field>
<set_empty_string>N</set_empty_string>
<length>-1</length>
<name>aggField</name>
<precision>-1</precision>
<type>String</type>
</field>
<field>
<set_empty_string>N</set_empty_string>
<length>-1</length>
<name>aggSubject</name>
<precision>-1</precision>
<type>String</type>
</field>
<field>
<set_empty_string>N</set_empty_string>
<length>-1</length>
<name>aggType</name>
<precision>-1</precision>
<type>String</type>
</field>
<field>
<set_empty_string>N</set_empty_string>
<length>-1</length>
<name>aggValue</name>
<precision>-1</precision>
<type>String</type>
</field>
</fields>
<data>
<line>
<item>minB</item>
<item>b</item>
<item>5</item>
<item/>
</line>
<line>
<item>maxC</item>
<item>c</item>
<item>6</item>
<item/>
</line>
</data>
<attributes/>
<GUI>
<xloc>416</xloc>
<yloc>48</yloc>
</GUI>
</transform>
<transform>
<name>b</name>
<type>DataGrid</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<fields>
<field>
<set_empty_string>N</set_empty_string>
<length>-1</length>
<name>b</name>
<precision>-1</precision>
<type>String</type>
</field>
</fields>
<data>
<line>
<item>b1</item>
</line>
<line>
<item>b2</item>
</line>
<line>
<item>b3</item>
</line>
</data>
<attributes/>
<GUI>
<xloc>112</xloc>
<yloc>176</yloc>
</GUI>
</transform>
<transform>
<name>c</name>
<type>DataGrid</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<fields>
<field>
<set_empty_string>N</set_empty_string>
<length>-1</length>
<name>c</name>
<precision>-1</precision>
<type>String</type>
</field>
</fields>
<data>
<line>
<item>c1</item>
</line>
<line>
<item>c2</item>
</line>
<line>
<item>c3</item>
</line>
<line>
<item>c4</item>
</line>
<line>
<item>c5</item>
</line>
<line>
<item>c6</item>
</line>
</data>
<attributes/>
<GUI>
<xloc>112</xloc>
<yloc>256</yloc>
</GUI>
</transform>
<transform>
<name>groups</name>
<type>DataGrid</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<fields>
<field>
<set_empty_string>N</set_empty_string>
<length>-1</length>
<name>group</name>
<precision>-1</precision>
<type>String</type>
</field>
</fields>
<data>
<line>
<item>a</item>
</line>
</data>
<attributes/>
<GUI>
<xloc>304</xloc>
<yloc>48</yloc>
</GUI>
</transform>
<transform_error_handling>
</transform_error_handling>
<attributes/>
</pipeline>