filter sales industri while extract data adempiere

1 files changed, 133 insertions, 12 deletions

diff --git a/import_adempiere_to_data_warehouse.ktr b/import_adempiere_to_data_warehouse.ktr
index d72119e..dc913d7 100644
--- a/import_adempiere_to_data_warehouse.ktr
+++ b/import_adempiere_to_data_warehouse.ktr
@@ -554,11 +554,6 @@
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>data trx adempiere</from>
-      <to>data trx adem</to>
-      <enabled>Y</enabled>
-    </hop>
-    <hop>
       <from>table bp altama</from>
       <to>bp altama</to>
       <enabled>Y</enabled>
@@ -608,6 +603,26 @@
       <to>insert update adempiere dw indoteknik</to>
       <enabled>Y</enabled>
     </hop>
+    <hop>
+      <from>data trx adempiere</from>
+      <to>Add constants</to>
+      <enabled>Y</enabled>
+    </hop>
+    <hop>
+      <from>Add constants</from>
+      <to>Filter rows</to>
+      <enabled>Y</enabled>
+    </hop>
+    <hop>
+      <from>Filter rows</from>
+      <to>data trx adem</to>
+      <enabled>Y</enabled>
+    </hop>
+    <hop>
+      <from>Filter rows</from>
+      <to>Write to log</to>
+      <enabled>Y</enabled>
+    </hop>
   </order>
   <step>
     <name>Merge join</name>
@@ -673,7 +688,7 @@
     </remotesteps>
     <GUI>
       <xloc>656</xloc>
-      <yloc>144</yloc>
+      <yloc>192</yloc>
       <draw>Y</draw>
     </GUI>
   </step>
@@ -1084,7 +1099,7 @@
     </remotesteps>
     <GUI>
       <xloc>208</xloc>
-      <yloc>80</yloc>
+      <yloc>128</yloc>
       <draw>Y</draw>
     </GUI>
   </step>
@@ -1620,7 +1635,7 @@ where reference_number is not null</sql>
     </remotesteps>
     <GUI>
       <xloc>208</xloc>
-      <yloc>192</yloc>
+      <yloc>240</yloc>
       <draw>Y</draw>
     </GUI>
   </step>
@@ -1704,7 +1719,7 @@ where reference_number is not null</sql>
     </remotesteps>
     <GUI>
       <xloc>544</xloc>
-      <yloc>192</yloc>
+      <yloc>240</yloc>
       <draw>Y</draw>
     </GUI>
   </step>
@@ -1746,7 +1761,7 @@ where reference_number is not null</sql>
     </remotesteps>
     <GUI>
       <xloc>544</xloc>
-      <yloc>80</yloc>
+      <yloc>128</yloc>
       <draw>Y</draw>
     </GUI>
   </step>
@@ -1806,7 +1821,7 @@ where reference_number is not null</sql>
     </remotesteps>
     <GUI>
       <xloc>416</xloc>
-      <yloc>80</yloc>
+      <yloc>128</yloc>
       <draw>Y</draw>
     </GUI>
   </step>
@@ -2086,7 +2101,113 @@ where reference_number is not null</sql>
     </remotesteps>
     <GUI>
       <xloc>416</xloc>
-      <yloc>192</yloc>
+      <yloc>240</yloc>
+      <draw>Y</draw>
+    </GUI>
+  </step>
+  <step>
+    <name>Filter rows</name>
+    <type>FilterRows</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <send_true_to>data trx adem</send_true_to>
+    <send_false_to>Write to log</send_false_to>
+    <compare>
+      <condition>
+        <negated>N</negated>
+        <leftvalue>salesperson</leftvalue>
+        <function>=</function>
+        <rightvalue>const_sales</rightvalue>
+      </condition>
+    </compare>
+    <attributes/>
+    <cluster_schema/>
+    <remotesteps>
+      <input>
+      </input>
+      <output>
+      </output>
+    </remotesteps>
+    <GUI>
+      <xloc>544</xloc>
+      <yloc>16</yloc>
+      <draw>Y</draw>
+    </GUI>
+  </step>
+  <step>
+    <name>Add constants</name>
+    <type>Constant</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <fields>
+      <field>
+        <name>const_sales</name>
+        <type/>
+        <format/>
+        <currency/>
+        <decimal/>
+        <group/>
+        <nullif>SALES INDUSTRI</nullif>
+        <length>-1</length>
+        <precision>-1</precision>
+        <set_empty_string>N</set_empty_string>
+      </field>
+    </fields>
+    <attributes/>
+    <cluster_schema/>
+    <remotesteps>
+      <input>
+      </input>
+      <output>
+      </output>
+    </remotesteps>
+    <GUI>
+      <xloc>416</xloc>
+      <yloc>16</yloc>
+      <draw>Y</draw>
+    </GUI>
+  </step>
+  <step>
+    <name>Write to log</name>
+    <type>WriteToLog</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <loglevel>log_level_basic</loglevel>
+    <displayHeader>Y</displayHeader>
+    <limitRows>N</limitRows>
+    <limitRowsNumber>0</limitRowsNumber>
+    <logmessage/>
+    <fields>
+      </fields>
+    <attributes/>
+    <cluster_schema/>
+    <remotesteps>
+      <input>
+      </input>
+      <output>
+      </output>
+    </remotesteps>
+    <GUI>
+      <xloc>656</xloc>
+      <yloc>16</yloc>
       <draw>Y</draw>
     </GUI>
   </step>