summaryrefslogtreecommitdiff
path: root/magento_has_sync.ktr
diff options
context:
space:
mode:
Diffstat (limited to 'magento_has_sync.ktr')
-rw-r--r--magento_has_sync.ktr59
1 files changed, 53 insertions, 6 deletions
diff --git a/magento_has_sync.ktr b/magento_has_sync.ktr
index cf62f7b..955389d 100644
--- a/magento_has_sync.ktr
+++ b/magento_has_sync.ktr
@@ -570,11 +570,6 @@
<enabled>Y</enabled>
</hop>
<hop>
- <from>Select values</from>
- <to>Merge join</to>
- <enabled>Y</enabled>
- </hop>
- <hop>
<from>Merge join</from>
<to>Select values 2</to>
<enabled>Y</enabled>
@@ -594,6 +589,16 @@
<to>Update 2</to>
<enabled>Y</enabled>
</hop>
+ <hop>
+ <from>Select values</from>
+ <to>Sort rows</to>
+ <enabled>Y</enabled>
+ </hop>
+ <hop>
+ <from>Sort rows</from>
+ <to>Merge join</to>
+ <enabled>Y</enabled>
+ </hop>
</order>
<step>
<name>Add constants</name>
@@ -658,7 +663,7 @@
<schema_name/>
</partitioning>
<join_type>INNER</join_type>
- <step1>Select values</step1>
+ <step1>Sort rows</step1>
<step2>Table input 2</step2>
<keys_1>
<key>variant_id</key>
@@ -993,6 +998,48 @@ order by id</sql>
<draw>Y</draw>
</GUI>
</step>
+ <step>
+ <name>Sort rows</name>
+ <type>SortRows</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>
+ <sort_size>1000000</sort_size>
+ <free_memory/>
+ <compress>N</compress>
+ <compress_variable/>
+ <unique_rows>N</unique_rows>
+ <fields>
+ <field>
+ <name>variant_id</name>
+ <ascending>Y</ascending>
+ <case_sensitive>N</case_sensitive>
+ <collator_enabled>N</collator_enabled>
+ <collator_strength>0</collator_strength>
+ <presorted>N</presorted>
+ </field>
+ </fields>
+ <attributes/>
+ <cluster_schema/>
+ <remotesteps>
+ <input>
+ </input>
+ <output>
+ </output>
+ </remotesteps>
+ <GUI>
+ <xloc>560</xloc>
+ <yloc>112</yloc>
+ <draw>Y</draw>
+ </GUI>
+ </step>
<step_error_handling>
</step_error_handling>
<slave-step-copy-partition-distribution>