| <?xml version="1.0" encoding="UTF-8"?> |
| <pipeline> |
| <info> |
| <name>Execute a transformation stored in a String</name> |
| <description/> |
| <extended_description/> |
| <trans_version/> |
| <trans_type>Normal</trans_type> |
| <trans_status>0</trans_status> |
| <directory>/</directory> |
| <parameters> |
| </parameters> |
| <log> |
| <pipeline-log-table> |
| <connection/> |
| <schema/> |
| <table/> |
| <size_limit_lines/> |
| <interval/> |
| <timeout_days/> |
| <field> |
| <id>ID_BATCH</id> |
| <enabled>Y</enabled> |
| <name>ID_BATCH</name> |
| </field> |
| <field> |
| <id>CHANNEL_ID</id> |
| <enabled>N</enabled> |
| <name>CHANNEL_ID</name> |
| </field> |
| <field> |
| <id>TRANSNAME</id> |
| <enabled>Y</enabled> |
| <name>TRANSNAME</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> |
| <subject/> |
| </field> |
| <field> |
| <id>LINES_WRITTEN</id> |
| <enabled>Y</enabled> |
| <name>LINES_WRITTEN</name> |
| <subject/> |
| </field> |
| <field> |
| <id>LINES_UPDATED</id> |
| <enabled>Y</enabled> |
| <name>LINES_UPDATED</name> |
| <subject/> |
| </field> |
| <field> |
| <id>LINES_INPUT</id> |
| <enabled>Y</enabled> |
| <name>LINES_INPUT</name> |
| <subject/> |
| </field> |
| <field> |
| <id>LINES_OUTPUT</id> |
| <enabled>Y</enabled> |
| <name>LINES_OUTPUT</name> |
| <subject/> |
| </field> |
| <field> |
| <id>LINES_REJECTED</id> |
| <enabled>N</enabled> |
| <name>LINES_REJECTED</name> |
| <subject/> |
| </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>N</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>CLIENT</id> |
| <enabled>N</enabled> |
| <name>CLIENT</name> |
| </field> |
| </pipeline-log-table> |
| <perf-log-table> |
| <connection/> |
| <schema/> |
| <table/> |
| <interval/> |
| <timeout_days/> |
| <field> |
| <id>ID_BATCH</id> |
| <enabled>Y</enabled> |
| <name>ID_BATCH</name> |
| </field> |
| <field> |
| <id>SEQ_NR</id> |
| <enabled>Y</enabled> |
| <name>SEQ_NR</name> |
| </field> |
| <field> |
| <id>LOGDATE</id> |
| <enabled>Y</enabled> |
| <name>LOGDATE</name> |
| </field> |
| <field> |
| <id>TRANSNAME</id> |
| <enabled>Y</enabled> |
| <name>TRANSNAME</name> |
| </field> |
| <field> |
| <id>STEPNAME</id> |
| <enabled>Y</enabled> |
| <name>STEPNAME</name> |
| </field> |
| <field> |
| <id>STEP_COPY</id> |
| <enabled>Y</enabled> |
| <name>STEP_COPY</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>INPUT_BUFFER_ROWS</id> |
| <enabled>Y</enabled> |
| <name>INPUT_BUFFER_ROWS</name> |
| </field> |
| <field> |
| <id>OUTPUT_BUFFER_ROWS</id> |
| <enabled>Y</enabled> |
| <name>OUTPUT_BUFFER_ROWS</name> |
| </field> |
| </perf-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> |
| <transform-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>TRANSNAME</id> |
| <enabled>Y</enabled> |
| <name>TRANSNAME</name> |
| </field> |
| <field> |
| <id>STEPNAME</id> |
| <enabled>Y</enabled> |
| <name>STEPNAME</name> |
| </field> |
| <field> |
| <id>STEP_COPY</id> |
| <enabled>Y</enabled> |
| <name>STEP_COPY</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>LOG_FIELD</id> |
| <enabled>N</enabled> |
| <name>LOG_FIELD</name> |
| </field> |
| </transform-log-table> |
| <metrics-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>METRICS_DATE</id> |
| <enabled>Y</enabled> |
| <name>METRICS_DATE</name> |
| </field> |
| <field> |
| <id>METRICS_CODE</id> |
| <enabled>Y</enabled> |
| <name>METRICS_CODE</name> |
| </field> |
| <field> |
| <id>METRICS_DESCRIPTION</id> |
| <enabled>Y</enabled> |
| <name>METRICS_DESCRIPTION</name> |
| </field> |
| <field> |
| <id>METRICS_SUBJECT</id> |
| <enabled>Y</enabled> |
| <name>METRICS_SUBJECT</name> |
| </field> |
| <field> |
| <id>METRICS_TYPE</id> |
| <enabled>Y</enabled> |
| <name>METRICS_TYPE</name> |
| </field> |
| <field> |
| <id>METRICS_VALUE</id> |
| <enabled>Y</enabled> |
| <name>METRICS_VALUE</name> |
| </field> |
| </metrics-log-table> |
| </log> |
| <maxdate> |
| <connection/> |
| <table/> |
| <field/> |
| <offset>0.0</offset> |
| <maxdiff>0.0</maxdiff> |
| </maxdate> |
| <size_rowset>1000</size_rowset> |
| <sleep_time_empty>1</sleep_time_empty> |
| <sleep_time_full>1</sleep_time_full> |
| <unique_connections>N</unique_connections> |
| <feedback_shown>Y</feedback_shown> |
| <feedback_size>5000</feedback_size> |
| <using_thread_priorities>Y</using_thread_priorities> |
| <shared_objects_file/> |
| <capture_transform_performance>N</capture_transform_performance> |
| <transform_performance_capturing_delay>1000</transform_performance_capturing_delay> |
| <transform_performance_capturing_size_limit/> |
| <dependencies> |
| </dependencies> |
| <partitionschemas> |
| </partitionschemas> |
| <slaveservers> |
| <slaveserver> |
| <name>CARTE</name> |
| <hostname>${CARTE_HOSTNAME}</hostname> |
| <port>${CARTE_PORT}</port> |
| <webAppName/> |
| <username>${CARTE_USER}</username> |
| <password>${CARTE_PWD}</password> <proxy_hostname>${CARTE_PROXY_HOST}</proxy_hostname> |
| <proxy_port>${CARTE_PROXY_PORT}</proxy_port> |
| <non_proxy_hosts>${CARTE_NON_PROXY}</non_proxy_hosts> |
| <master>Y</master> |
| <sslMode>N</sslMode> </slaveserver> |
| </slaveservers> |
| <clusterschemas> |
| </clusterschemas> |
| <created_user/> |
| <created_date>2010/10/08 15:51:58.308</created_date> |
| <modified_user/> |
| <modified_date>2007/09/11 21:34:50.919</modified_date> |
| <key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key> |
| <is_key_private>N</is_key_private> |
| </info> |
| <notepads> |
| <notepad> |
| <note>XML/KTR Source</note> |
| <xloc>78</xloc> |
| <yloc>160</yloc> |
| <width>110</width> |
| <heigth>25</heigth> |
| <fontname>Arial</fontname> |
| <fontsize>10</fontsize> |
| <fontbold>N</fontbold> |
| <fontitalic>N</fontitalic> |
| <fontcolorred>0</fontcolorred> |
| <fontcolorgreen>0</fontcolorgreen> |
| <fontcolorblue>0</fontcolorblue> |
| <backgroundcolorred>255</backgroundcolorred> |
| <backgroundcolorgreen>165</backgroundcolorgreen> |
| <backgroundcolorblue>0</backgroundcolorblue> |
| <bordercolorred>100</bordercolorred> |
| <bordercolorgreen>100</bordercolorgreen> |
| <bordercolorblue>100</bordercolorblue> |
| <drawshadow>Y</drawshadow> |
| </notepad> |
| </notepads> |
| <order> |
| <hop> |
| <from>Data Grid</from> |
| <to>User Defined Java Class</to> |
| <enabled>Y</enabled> |
| </hop> |
| </order> |
| <transform> |
| <name>Data Grid</name> |
| <type>DataGrid</type> |
| <description/> |
| <distribute>Y</distribute> |
| <custom_distribution/> |
| <copies>1</copies> |
| <partitioning> |
| <method>none</method> |
| <schema_name/> |
| </partitioning> |
| <fields> |
| <field> |
| <name>xml</name> |
| <type>String</type> |
| <format/> |
| <currency/> |
| <decimal/> |
| <group/> |
| <length>-1</length> |
| <precision>-1</precision> |
| <set_empty_string>N</set_empty_string> |
| </field> |
| </fields> |
| <data> |
| <line> <item><?xml version="1.0" encoding="UTF-8"?>
<transformation>
 <info>
 <name/>
 <directory>&#47;</directory>
 <log>
 <read/>
 <write/>
 <input/>
 <output/>
 <update/>
 <connection/>
 <table/>
 <use_batchid>Y</use_batchid>
 <use_logfield>N</use_logfield>
 </log>
 <maxdate>
 <connection/>
 <table/>
 <field/>
 <offset>0.0</offset>
 <maxdiff>0.0</maxdiff>
 </maxdate>
 <size_rowset>1000</size_rowset>
 <sleep_time_empty>1</sleep_time_empty>
 <sleep_time_full>1</sleep_time_full>
 <unique_connections>N</unique_connections>
 <feedback_shown>Y</feedback_shown>
 <feedback_size>5000</feedback_size>
 <dependencies>
 </dependencies>
 <partitionschemas>
 </partitionschemas>
 <modified_user>-</modified_user>
 <modified_date>2006&#47;10&#47;24 11:39:02.963</modified_date>
 </info>
 <notepads>
 <notepad>
 <note>If you do a preview on the Result transform you will note that the generated ID is unique.
If you specify another counter name in either of the sequence generator transforms, you will get duplicates.

Step &quot;Generate Rows&quot; does not actually produce output. It creates 1000 empty lines and splits them evenly
before they reach the two &quot;Generate ID&quot; transforms (transform type &quot;sequence generator&quot;). Both sequence generators
do have the same &quot;Counter name&quot; (double click to edit and see the &quot;Counter name&quot; value). That makes the
generated ids unique, even though they are produced by two different sequence generators.</note>
 <xloc>32</xloc>
 <yloc>28</yloc>
 <width>535</width>
 <heigth>101</heigth>
 </notepad>
 <notepad>
 <note>You basically get the same result if you have 2 row generators (both generating 20 lines, with no
actual output) that are linked to two ID sequence generators. Both ID sequence generators have got the
same &quot;counter name&quot; and thus the finally created IDs are unique. The difference to the example above is
that the generated IDs are in order (enumerated from 1..40).</note>
 <xloc>45</xloc>
 <yloc>472</yloc>
 <width>516</width>
 <heigth>62</heigth>
 </notepad>
 </notepads>
 <order>
 <hop> <from>Generate Rows</from><to>Generate ID</to><enabled>Y</enabled> </hop> <hop> <from>Generate ID</from><to>Result</to><enabled>Y</enabled> </hop> <hop> <from>Generate ID (2)</from><to>Result</to><enabled>Y</enabled> </hop> <hop> <from>Generate Rows</from><to>Generate ID (2)</to><enabled>Y</enabled> </hop> <hop> <from>Row Gen [1]</from><to>Gen ID [1]</to><enabled>Y</enabled> </hop> <hop> <from>Row Gen [2]</from><to>Gen ID [2]</to><enabled>Y</enabled> </hop> <hop> <from>Gen ID [1]</from><to>Result 2</to><enabled>Y</enabled> </hop> <hop> <from>Gen ID [2]</from><to>Result 2</to><enabled>Y</enabled> </hop> </order>

 <transform>
 <name>Generate ID</name>
 <type>Sequence</type>
 <description/>
 <distribute>Y</distribute>
 <copies>1</copies>
 <partitioning>
 <method>none</method>
 <field_name/>
 <schema_name/>
 </partitioning>
 <valuename>ID</valuename>
 <use_database>N</use_database>
 <connection/>
 <seqname>SEQ_</seqname>
 <use_counter>Y</use_counter>
 <counter_name>id-counter</counter_name>
 <start_at>1</start_at>
 <increment_by>1</increment_by>
 <max_value>9999999</max_value>
 <GUI>
 <xloc>355</xloc>
 <yloc>179</yloc>
 <draw>Y</draw>
 </GUI>
 </transform>

 <transform>
 <name>Generate ID (2)</name>
 <type>Sequence</type>
 <description/>
 <distribute>Y</distribute>
 <copies>1</copies>
 <partitioning>
 <method>none</method>
 <field_name/>
 <schema_name/>
 </partitioning>
 <valuename>ID</valuename>
 <use_database>N</use_database>
 <connection/>
 <seqname>SEQ_</seqname>
 <use_counter>Y</use_counter>
 <counter_name>id-counter</counter_name>
 <start_at>1</start_at>
 <increment_by>1</increment_by>
 <max_value>9999999</max_value>
 <GUI>
 <xloc>360</xloc>
 <yloc>361</yloc>
 <draw>Y</draw>
 </GUI>
 </transform>

 <transform>
 <name>Generate Rows</name>
 <type>RowGenerator</type>
 <description/>
 <distribute>Y</distribute>
 <copies>1</copies>
 <partitioning>
 <method>none</method>
 <field_name/>
 <schema_name/>
 </partitioning>
 <fields>
 </fields>
 <limit>40</limit>
 <GUI>
 <xloc>188</xloc>
 <yloc>267</yloc>
 <draw>Y</draw>
 </GUI>
 </transform>

 <transform>
 <name>Result</name>
 <type>Dummy</type>
 <description/>
 <distribute>Y</distribute>
 <copies>1</copies>
 <partitioning>
 <method>none</method>
 <field_name/>
 <schema_name/>
 </partitioning>
 <GUI>
 <xloc>563</xloc>
 <yloc>251</yloc>
 <draw>Y</draw>
 </GUI>
 </transform>

 <transform>
 <name>Row Gen [1]</name>
 <type>RowGenerator</type>
 <description/>
 <distribute>Y</distribute>
 <copies>1</copies>
 <partitioning>
 <method>none</method>
 <field_name/>
 <schema_name/>
 </partitioning>
 <fields>
 </fields>
 <limit>20</limit>
 <GUI>
 <xloc>158</xloc>
 <yloc>631</yloc>
 <draw>Y</draw>
 </GUI>
 </transform>

 <transform>
 <name>Row Gen [2]</name>
 <type>RowGenerator</type>
 <description/>
 <distribute>Y</distribute>
 <copies>1</copies>
 <partitioning>
 <method>none</method>
 <field_name/>
 <schema_name/>
 </partitioning>
 <fields>
 </fields>
 <limit>20</limit>
 <GUI>
 <xloc>157</xloc>
 <yloc>698</yloc>
 <draw>Y</draw>
 </GUI>
 </transform>

 <transform>
 <name>Gen ID [1]</name>
 <type>Sequence</type>
 <description/>
 <distribute>Y</distribute>
 <copies>1</copies>
 <partitioning>
 <method>none</method>
 <field_name/>
 <schema_name/>
 </partitioning>
 <valuename>AnotherID</valuename>
 <use_database>N</use_database>
 <connection/>
 <seqname>SEQ_</seqname>
 <use_counter>Y</use_counter>
 <counter_name>another-counter</counter_name>
 <start_at>1</start_at>
 <increment_by>1</increment_by>
 <max_value>9999999</max_value>
 <GUI>
 <xloc>352</xloc>
 <yloc>576</yloc>
 <draw>Y</draw>
 </GUI>
 </transform>

 <transform>
 <name>Gen ID [2]</name>
 <type>Sequence</type>
 <description/>
 <distribute>Y</distribute>
 <copies>1</copies>
 <partitioning>
 <method>none</method>
 <field_name/>
 <schema_name/>
 </partitioning>
 <valuename>AnotherID</valuename>
 <use_database>N</use_database>
 <connection/>
 <seqname>SEQ_</seqname>
 <use_counter>Y</use_counter>
 <counter_name>another-counter</counter_name>
 <start_at>1</start_at>
 <increment_by>1</increment_by>
 <max_value>9999999</max_value>
 <GUI>
 <xloc>351</xloc>
 <yloc>736</yloc>
 <draw>Y</draw>
 </GUI>
 </transform>

 <transform>
 <name>Result 2</name>
 <type>Dummy</type>
 <description/>
 <distribute>Y</distribute>
 <copies>1</copies>
 <partitioning>
 <method>none</method>
 <field_name/>
 <schema_name/>
 </partitioning>
 <GUI>
 <xloc>568</xloc>
 <yloc>655</yloc>
 <draw>Y</draw>
 </GUI>
 </transform>

</transformation>
</item> </line> |
| </data> |
| <cluster_schema/> |
| |
| <input> |
| </input> |
| <output> |
| </output> |
| |
| <GUI> |
| <xloc>110</xloc> |
| <yloc>95</yloc> |
| <draw>Y</draw> |
| </GUI> |
| </transform> |
| |
| <transform> |
| <name>User Defined Java Class</name> |
| <type>UserDefinedJavaClass</type> |
| <description/> |
| <distribute>Y</distribute> |
| <custom_distribution/> |
| <copies>1</copies> |
| <partitioning> |
| <method>none</method> |
| <schema_name/> |
| </partitioning> |
| |
| <definitions> |
| <definition> |
| <class_type>TRANSFORM_CLASS</class_type> |
| |
| <class_name>Processor</class_name> |
| |
| <class_source><![CDATA[import java.util.*; |
| import org.pentaho.di.core.xml.*; |
| import org.pentaho.di.pipeline.*; |
| import org.w3c.dom.*; |
| |
| private int yearIndex; |
| private Calendar calendar; |
| |
| public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException |
| { |
| Object[] r=getRow(); |
| if (r==null) |
| { |
| setOutputDone(); |
| return false; |
| } |
| |
| String ktr = getInputRowMeta().getString(r, "xml", null); |
| Document doc = XMLHandler.loadXMLString( ktr ); |
| Node transNode = XMLHandler.getSubNode(doc, TransMeta.XML_TAG); |
| |
| TransMeta pipelineMeta = new TransMeta(transNode, getTrans().getRepository()); |
| Trans pipeline = new Trans(pipelineMeta, getTrans()); |
| pipeline.execute( null ); |
| |
| // Just pass the input along |
| // |
| putRow(getInputRowMeta(), r); |
| |
| return true; |
| } |
| ]]></class_source> |
| </definition> |
| </definitions> |
| <fields> |
| </fields><clear_result_fields>N</clear_result_fields> |
| <info_transforms></info_transforms><target_transforms></target_transforms><usage_parameters></usage_parameters> <cluster_schema/> |
| |
| <input> |
| </input> |
| <output> |
| </output> |
| |
| <GUI> |
| <xloc>289</xloc> |
| <yloc>95</yloc> |
| <draw>Y</draw> |
| </GUI> |
| </transform> |
| |
| <transform_error_handling> |
| </transform_error_handling> |
| <slave-transform-copy-partition-distribution> |
| </slave-transform-copy-partition-distribution> |
| <slave_transformation>N</slave_transformation> |
| </pipeline> |
