diff options
| -rw-r--r-- | import_brand.ktr | 128 | ||||
| -rw-r--r-- | import_product_product.ktr | 178 | ||||
| -rw-r--r-- | import_purchase_order.ktr | 228 | ||||
| -rw-r--r-- | import_purchase_pricelist.ktr | 168 | ||||
| -rw-r--r-- | insert_update_pricelist.ktr | 134 | ||||
| -rw-r--r-- | insert_update_pricelist1.ktr | 176 | ||||
| -rw-r--r-- | insert_update_pricelist2.ktr | 176 | ||||
| -rw-r--r-- | insert_update_pricelist3.ktr | 176 | ||||
| -rw-r--r-- | insert_update_pricelist4.ktr | 176 | ||||
| -rw-r--r-- | insert_update_pricelist5.ktr | 176 |
10 files changed, 858 insertions, 858 deletions
diff --git a/import_brand.ktr b/import_brand.ktr index 7b0d313..122b864 100644 --- a/import_brand.ktr +++ b/import_brand.ktr @@ -545,69 +545,6 @@ </hop> </order> <step> - <name>dw Insert / update brand</name> - <type>InsertUpdate</type> - <description/> - <distribute>Y</distribute> - <custom_distribution/> - <copies>1</copies> - <partitioning> - <method>none</method> - <schema_name/> - </partitioning> - <connection>dw bi indoteknik (localhost)</connection> - <commit>100</commit> - <update_bypassed>N</update_bypassed> - <lookup> - <schema>public</schema> - <table>brand</table> - <key> - <name>id</name> - <field>id</field> - <condition>=</condition> - <name2/> - </key> - <value> - <name>id</name> - <rename>id</rename> - <update>N</update> - </value> - <value> - <name>name</name> - <rename>x_name</rename> - <update>Y</update> - </value> - <value> - <name>type</name> - <rename>x_manufacture_level</rename> - <update>Y</update> - </value> - <value> - <name>parent</name> - <rename>parent</rename> - <update>Y</update> - </value> - <value> - <name>pricing_group</name> - <rename>pricing_group</rename> - <update>Y</update> - </value> - </lookup> - <attributes/> - <cluster_schema/> - <remotesteps> - <input> - </input> - <output> - </output> - </remotesteps> - <GUI> - <xloc>272</xloc> - <yloc>96</yloc> - <draw>Y</draw> - </GUI> - </step> - <step> <name>Table input</name> <type>TableInput</type> <description/> @@ -622,7 +559,7 @@ <sql>select id, x_name, x_manufacture_level, (select x_name from x_manufactures xm2 where xm2.id = xm.parent_id) as parent, pricing_group from x_manufactures xm -where xm.write_date >= (now() - '15 days'::interval)</sql> +--where xm.write_date >= (now() - '15 days'::interval)</sql> <limit>0</limit> <lookup/> <execute_each_row>N</execute_each_row> @@ -760,6 +697,69 @@ where xm.write_date >= (now() - '15 days'::interval)</sql> <draw>Y</draw> </GUI> </step> + <step> + <name>dw Insert / update brand</name> + <type>InsertUpdate</type> + <description/> + <distribute>Y</distribute> + <custom_distribution/> + <copies>1</copies> + <partitioning> + <method>none</method> + <schema_name/> + </partitioning> + <connection>dw bi indoteknik (localhost)</connection> + <commit>100</commit> + <update_bypassed>N</update_bypassed> + <lookup> + <schema>public</schema> + <table>brand</table> + <key> + <name>id</name> + <field>id</field> + <condition>=</condition> + <name2/> + </key> + <value> + <name>id</name> + <rename>id</rename> + <update>N</update> + </value> + <value> + <name>name</name> + <rename>x_name</rename> + <update>Y</update> + </value> + <value> + <name>type</name> + <rename>x_manufacture_level</rename> + <update>Y</update> + </value> + <value> + <name>parent</name> + <rename>parent</rename> + <update>Y</update> + </value> + <value> + <name>pricing_group</name> + <rename>pricing_group</rename> + <update>Y</update> + </value> + </lookup> + <attributes/> + <cluster_schema/> + <remotesteps> + <input> + </input> + <output> + </output> + </remotesteps> + <GUI> + <xloc>272</xloc> + <yloc>96</yloc> + <draw>Y</draw> + </GUI> + </step> <step_error_handling> </step_error_handling> <slave-step-copy-partition-distribution> diff --git a/import_product_product.ktr b/import_product_product.ktr index 8ab3062..c5dbfc6 100644 --- a/import_product_product.ktr +++ b/import_product_product.ktr @@ -545,94 +545,6 @@ </hop> </order> <step> - <name>dw Insert / update product</name> - <type>InsertUpdate</type> - <description/> - <distribute>Y</distribute> - <custom_distribution/> - <copies>1</copies> - <partitioning> - <method>none</method> - <schema_name/> - </partitioning> - <connection>dw bi indoteknik (localhost)</connection> - <commit>100</commit> - <update_bypassed>N</update_bypassed> - <lookup> - <schema>public</schema> - <table>product</table> - <key> - <name>product_id</name> - <field>product_id</field> - <condition>=</condition> - <name2/> - </key> - <value> - <name>product_id</name> - <rename>product_id</rename> - <update>N</update> - </value> - <value> - <name>template_id</name> - <rename>template_id</rename> - <update>Y</update> - </value> - <value> - <name>name</name> - <rename>name</rename> - <update>Y</update> - </value> - <value> - <name>active</name> - <rename>active</rename> - <update>Y</update> - </value> - <value> - <name>brand_id</name> - <rename>brand_id</rename> - <update>Y</update> - </value> - <value> - <name>item_code</name> - <rename>item_code</rename> - <update>Y</update> - </value> - <value> - <name>parent_category</name> - <rename>parent_category</rename> - <update>Y</update> - </value> - <value> - <name>image</name> - <rename>image</rename> - <update>Y</update> - </value> - <value> - <name>description</name> - <rename>description</rename> - <update>Y</update> - </value> - <value> - <name>weight</name> - <rename>weight</rename> - <update>Y</update> - </value> - </lookup> - <attributes/> - <cluster_schema/> - <remotesteps> - <input> - </input> - <output> - </output> - </remotesteps> - <GUI> - <xloc>448</xloc> - <yloc>128</yloc> - <draw>Y</draw> - </GUI> - </step> - <step> <name>Table input</name> <type>TableInput</type> <description/> @@ -654,7 +566,7 @@ pt.website_description as description, pt.weight from product_product pp join product_template pt on pt.id = pp.product_tmpl_id -where pp.write_date >= (now() - '5 days'::interval)</sql> +--where pp.write_date >= (now() - '5 days'::interval)</sql> <limit>0</limit> <lookup/> <execute_each_row>N</execute_each_row> @@ -907,6 +819,94 @@ where pp.write_date >= (now() - '5 days'::interval)</sql> <draw>Y</draw> </GUI> </step> + <step> + <name>dw Insert / update product</name> + <type>InsertUpdate</type> + <description/> + <distribute>Y</distribute> + <custom_distribution/> + <copies>1</copies> + <partitioning> + <method>none</method> + <schema_name/> + </partitioning> + <connection>dw bi indoteknik (localhost)</connection> + <commit>100</commit> + <update_bypassed>N</update_bypassed> + <lookup> + <schema>public</schema> + <table>product</table> + <key> + <name>product_id</name> + <field>product_id</field> + <condition>=</condition> + <name2/> + </key> + <value> + <name>product_id</name> + <rename>product_id</rename> + <update>N</update> + </value> + <value> + <name>template_id</name> + <rename>template_id</rename> + <update>Y</update> + </value> + <value> + <name>name</name> + <rename>name</rename> + <update>Y</update> + </value> + <value> + <name>active</name> + <rename>active</rename> + <update>Y</update> + </value> + <value> + <name>brand_id</name> + <rename>brand_id</rename> + <update>Y</update> + </value> + <value> + <name>item_code</name> + <rename>item_code</rename> + <update>Y</update> + </value> + <value> + <name>parent_category</name> + <rename>parent_category</rename> + <update>Y</update> + </value> + <value> + <name>image</name> + <rename>image</rename> + <update>Y</update> + </value> + <value> + <name>description</name> + <rename>description</rename> + <update>Y</update> + </value> + <value> + <name>weight</name> + <rename>weight</rename> + <update>Y</update> + </value> + </lookup> + <attributes/> + <cluster_schema/> + <remotesteps> + <input> + </input> + <output> + </output> + </remotesteps> + <GUI> + <xloc>448</xloc> + <yloc>128</yloc> + <draw>Y</draw> + </GUI> + </step> <step_error_handling> </step_error_handling> <slave-step-copy-partition-distribution> diff --git a/import_purchase_order.ktr b/import_purchase_order.ktr index f297a94..e548fbd 100644 --- a/import_purchase_order.ktr +++ b/import_purchase_order.ktr @@ -545,119 +545,6 @@ </hop> </order> <step> - <name>dw Insert / update po</name> - <type>InsertUpdate</type> - <description/> - <distribute>Y</distribute> - <custom_distribution/> - <copies>1</copies> - <partitioning> - <method>none</method> - <schema_name/> - </partitioning> - <connection>dw bi indoteknik (localhost)</connection> - <commit>100</commit> - <update_bypassed>N</update_bypassed> - <lookup> - <schema>public</schema> - <table>purchase_order_dw</table> - <key> - <name>line_id</name> - <field>line_id</field> - <condition>=</condition> - <name2/> - </key> - <value> - <name>po_date</name> - <rename>po_date</rename> - <update>Y</update> - </value> - <value> - <name>line_date</name> - <rename>line_date</rename> - <update>Y</update> - </value> - <value> - <name>documentno</name> - <rename>documentno</rename> - <update>Y</update> - </value> - <value> - <name>state</name> - <rename>state</rename> - <update>Y</update> - </value> - <value> - <name>partner_id</name> - <rename>partner_id</rename> - <update>Y</update> - </value> - <value> - <name>vendor</name> - <rename>vendor</rename> - <update>Y</update> - </value> - <value> - <name>product_id</name> - <rename>product_id</rename> - <update>Y</update> - </value> - <value> - <name>qty</name> - <rename>qty</rename> - <update>Y</update> - </value> - <value> - <name>price_unit</name> - <rename>price_unit</rename> - <update>Y</update> - </value> - <value> - <name>price_subtotal</name> - <rename>price_subtotal</rename> - <update>Y</update> - </value> - <value> - <name>line_id</name> - <rename>line_id</rename> - <update>N</update> - </value> - <value> - <name>year_month</name> - <rename>year_month</rename> - <update>Y</update> - </value> - <value> - <name>year_date</name> - <rename>year_date</rename> - <update>Y</update> - </value> - <value> - <name>month_date</name> - <rename>month_date</rename> - <update>Y</update> - </value> - <value> - <name>day_date</name> - <rename>day_date</rename> - <update>Y</update> - </value> - </lookup> - <attributes/> - <cluster_schema/> - <remotesteps> - <input> - </input> - <output> - </output> - </remotesteps> - <GUI> - <xloc>432</xloc> - <yloc>96</yloc> - <draw>Y</draw> - </GUI> - </step> - <step> <name>Table input</name> <type>TableInput</type> <description/> @@ -680,7 +567,7 @@ get_quarter(to_char(pol.write_date::timestamp with time zone, 'MM'::text)) from purchase_order po join res_partner rp on rp.id = po.partner_id join purchase_order_line pol on pol.order_id = po.id -where pol.write_date >= (now() - '5 days'::interval)</sql> +--where pol.write_date >= (now() - '5 days'::interval)</sql> <limit>0</limit> <lookup/> <execute_each_row>N</execute_each_row> @@ -1071,6 +958,119 @@ where pol.write_date >= (now() - '5 days'::interval)</sql> <draw>Y</draw> </GUI> </step> + <step> + <name>dw Insert / update po</name> + <type>InsertUpdate</type> + <description/> + <distribute>Y</distribute> + <custom_distribution/> + <copies>1</copies> + <partitioning> + <method>none</method> + <schema_name/> + </partitioning> + <connection>dw bi indoteknik (localhost)</connection> + <commit>100</commit> + <update_bypassed>N</update_bypassed> + <lookup> + <schema>public</schema> + <table>purchase_order_dw</table> + <key> + <name>line_id</name> + <field>line_id</field> + <condition>=</condition> + <name2/> + </key> + <value> + <name>po_date</name> + <rename>po_date</rename> + <update>Y</update> + </value> + <value> + <name>line_date</name> + <rename>line_date</rename> + <update>Y</update> + </value> + <value> + <name>documentno</name> + <rename>documentno</rename> + <update>Y</update> + </value> + <value> + <name>state</name> + <rename>state</rename> + <update>Y</update> + </value> + <value> + <name>partner_id</name> + <rename>partner_id</rename> + <update>Y</update> + </value> + <value> + <name>vendor</name> + <rename>vendor</rename> + <update>Y</update> + </value> + <value> + <name>product_id</name> + <rename>product_id</rename> + <update>Y</update> + </value> + <value> + <name>qty</name> + <rename>qty</rename> + <update>Y</update> + </value> + <value> + <name>price_unit</name> + <rename>price_unit</rename> + <update>Y</update> + </value> + <value> + <name>price_subtotal</name> + <rename>price_subtotal</rename> + <update>Y</update> + </value> + <value> + <name>line_id</name> + <rename>line_id</rename> + <update>N</update> + </value> + <value> + <name>year_month</name> + <rename>year_month</rename> + <update>Y</update> + </value> + <value> + <name>year_date</name> + <rename>year_date</rename> + <update>Y</update> + </value> + <value> + <name>month_date</name> + <rename>month_date</rename> + <update>Y</update> + </value> + <value> + <name>day_date</name> + <rename>day_date</rename> + <update>Y</update> + </value> + </lookup> + <attributes/> + <cluster_schema/> + <remotesteps> + <input> + </input> + <output> + </output> + </remotesteps> + <GUI> + <xloc>432</xloc> + <yloc>96</yloc> + <draw>Y</draw> + </GUI> + </step> <step_error_handling> </step_error_handling> <slave-step-copy-partition-distribution> diff --git a/import_purchase_pricelist.ktr b/import_purchase_pricelist.ktr index 384d7ff..2ab9f29 100644 --- a/import_purchase_pricelist.ktr +++ b/import_purchase_pricelist.ktr @@ -545,89 +545,6 @@ </hop> </order> <step> - <name>dw Insert / update purchase pl</name> - <type>InsertUpdate</type> - <description/> - <distribute>Y</distribute> - <custom_distribution/> - <copies>1</copies> - <partitioning> - <method>none</method> - <schema_name/> - </partitioning> - <connection>dw bi indoteknik (localhost)</connection> - <commit>100</commit> - <update_bypassed>N</update_bypassed> - <lookup> - <schema>public</schema> - <table>purchase_pricelist_dw</table> - <key> - <name>id</name> - <field>id</field> - <condition>=</condition> - <name2/> - </key> - <value> - <name>id</name> - <rename>id</rename> - <update>N</update> - </value> - <value> - <name>product_id</name> - <rename>product_id</rename> - <update>Y</update> - </value> - <value> - <name>vendor_id</name> - <rename>vendor_id</rename> - <update>Y</update> - </value> - <value> - <name>vendor</name> - <rename>vendor</rename> - <update>Y</update> - </value> - <value> - <name>product_price</name> - <rename>product_price</rename> - <update>Y</update> - </value> - <value> - <name>write_date</name> - <rename>write_date</rename> - <update>Y</update> - </value> - <value> - <name>system_price</name> - <rename>system_price</rename> - <update>Y</update> - </value> - <value> - <name>system_last_update</name> - <rename>system_last_update</rename> - <update>Y</update> - </value> - <value> - <name>human_last_update</name> - <rename>human_last_update</rename> - <update>Y</update> - </value> - </lookup> - <attributes/> - <cluster_schema/> - <remotesteps> - <input> - </input> - <output> - </output> - </remotesteps> - <GUI> - <xloc>512</xloc> - <yloc>336</yloc> - <draw>Y</draw> - </GUI> - </step> - <step> <name>Table input</name> <type>TableInput</type> <description/> @@ -643,7 +560,7 @@ pp.system_price, pp.system_last_update, pp.human_last_update from purchase_pricelist pp join res_partner rp on rp.id = pp.vendor_id -where pp.write_date >= (now() - '10 days'::interval)</sql> +--where pp.write_date >= (now() - '10 days'::interval)</sql> <limit>0</limit> <lookup/> <execute_each_row>N</execute_each_row> @@ -873,6 +790,89 @@ where pp.write_date >= (now() - '10 days'::interval)</sql> <draw>Y</draw> </GUI> </step> + <step> + <name>dw Insert / update purchase pl</name> + <type>InsertUpdate</type> + <description/> + <distribute>Y</distribute> + <custom_distribution/> + <copies>1</copies> + <partitioning> + <method>none</method> + <schema_name/> + </partitioning> + <connection>dw bi indoteknik (localhost)</connection> + <commit>100</commit> + <update_bypassed>N</update_bypassed> + <lookup> + <schema>public</schema> + <table>purchase_pricelist_dw</table> + <key> + <name>id</name> + <field>id</field> + <condition>=</condition> + <name2/> + </key> + <value> + <name>id</name> + <rename>id</rename> + <update>N</update> + </value> + <value> + <name>product_id</name> + <rename>product_id</rename> + <update>Y</update> + </value> + <value> + <name>vendor_id</name> + <rename>vendor_id</rename> + <update>Y</update> + </value> + <value> + <name>vendor</name> + <rename>vendor</rename> + <update>Y</update> + </value> + <value> + <name>product_price</name> + <rename>product_price</rename> + <update>Y</update> + </value> + <value> + <name>write_date</name> + <rename>write_date</rename> + <update>Y</update> + </value> + <value> + <name>system_price</name> + <rename>system_price</rename> + <update>Y</update> + </value> + <value> + <name>system_last_update</name> + <rename>system_last_update</rename> + <update>Y</update> + </value> + <value> + <name>human_last_update</name> + <rename>human_last_update</rename> + <update>Y</update> + </value> + </lookup> + <attributes/> + <cluster_schema/> + <remotesteps> + <input> + </input> + <output> + </output> + </remotesteps> + <GUI> + <xloc>512</xloc> + <yloc>336</yloc> + <draw>Y</draw> + </GUI> + </step> <step_error_handling> </step_error_handling> <slave-step-copy-partition-distribution> diff --git a/insert_update_pricelist.ktr b/insert_update_pricelist.ktr index 330a5d0..482819a 100644 --- a/insert_update_pricelist.ktr +++ b/insert_update_pricelist.ktr @@ -572,12 +572,12 @@ <hop> <from>p Insert / update base pl</from> <to>base solr flag pt</to> - <enabled>Y</enabled> + <enabled>N</enabled> </hop> <hop> <from>base solr flag pt</from> <to>base solr flag pp</to> - <enabled>Y</enabled> + <enabled>N</enabled> </hop> </order> <step> @@ -787,8 +787,8 @@ </GUI> </step> <step> - <name>base solr flag pt</name> - <type>InsertUpdate</type> + <name>Merge join</name> + <type>MergeJoin</type> <description/> <distribute>Y</distribute> <custom_distribution/> @@ -797,24 +797,15 @@ <method>none</method> <schema_name/> </partitioning> - <connection>erp indoteknik production (localhost)</connection> - <commit>100</commit> - <update_bypassed>N</update_bypassed> - <lookup> - <schema>public</schema> - <table>product_template</table> - <key> - <name>template_id</name> - <field>id</field> - <condition>=</condition> - <name2/> - </key> - <value> - <name>solr_flag</name> - <rename>solr_flag</rename> - <update>Y</update> - </value> - </lookup> + <join_type>LEFT OUTER</join_type> + <step1>price compute</step1> + <step2>price erp</step2> + <keys_1> + <key>product_id</key> + </keys_1> + <keys_2> + <key>product_id</key> + </keys_2> <attributes/> <cluster_schema/> <remotesteps> @@ -824,12 +815,44 @@ </output> </remotesteps> <GUI> - <xloc>912</xloc> + <xloc>320</xloc> <yloc>272</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_nothing</loglevel> + <displayHeader>Y</displayHeader> + <limitRows>N</limitRows> + <limitRowsNumber>0</limitRowsNumber> + <logmessage/> + <fields> + </fields> + <attributes/> + <cluster_schema/> + <remotesteps> + <input> + </input> + <output> + </output> + </remotesteps> + <GUI> + <xloc>464</xloc> + <yloc>400</yloc> + <draw>Y</draw> + </GUI> + </step> + <step> <name>base solr flag pp</name> <type>InsertUpdate</type> <description/> @@ -873,8 +896,8 @@ </GUI> </step> <step> - <name>Merge join</name> - <type>MergeJoin</type> + <name>base solr flag pt</name> + <type>InsertUpdate</type> <description/> <distribute>Y</distribute> <custom_distribution/> @@ -883,15 +906,24 @@ <method>none</method> <schema_name/> </partitioning> - <join_type>LEFT OUTER</join_type> - <step1>price compute</step1> - <step2>price erp</step2> - <keys_1> - <key>product_id</key> - </keys_1> - <keys_2> - <key>product_id</key> - </keys_2> + <connection>erp indoteknik production (localhost)</connection> + <commit>100</commit> + <update_bypassed>N</update_bypassed> + <lookup> + <schema>public</schema> + <table>product_template</table> + <key> + <name>template_id</name> + <field>id</field> + <condition>=</condition> + <name2/> + </key> + <value> + <name>solr_flag</name> + <rename>solr_flag</rename> + <update>Y</update> + </value> + </lookup> <attributes/> <cluster_schema/> <remotesteps> @@ -901,44 +933,12 @@ </output> </remotesteps> <GUI> - <xloc>320</xloc> + <xloc>912</xloc> <yloc>272</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_nothing</loglevel> - <displayHeader>Y</displayHeader> - <limitRows>N</limitRows> - <limitRowsNumber>0</limitRowsNumber> - <logmessage/> - <fields> - </fields> - <attributes/> - <cluster_schema/> - <remotesteps> - <input> - </input> - <output> - </output> - </remotesteps> - <GUI> - <xloc>464</xloc> - <yloc>400</yloc> - <draw>Y</draw> - </GUI> - </step> - <step> <name>p Insert / update base pl</name> <type>InsertUpdate</type> <description/> diff --git a/insert_update_pricelist1.ktr b/insert_update_pricelist1.ktr index d7ab991..660fa8e 100644 --- a/insert_update_pricelist1.ktr +++ b/insert_update_pricelist1.ktr @@ -572,12 +572,12 @@ <hop> <from>p Insert / update tier1</from> <to>pl1 solr flag pt</to> - <enabled>Y</enabled> + <enabled>N</enabled> </hop> <hop> <from>pl1 solr flag pt</from> <to>pl1 solr flag pp</to> - <enabled>Y</enabled> + <enabled>N</enabled> </hop> </order> <step> @@ -799,92 +799,6 @@ </GUI> </step> <step> - <name>pl1 solr flag pt</name> - <type>InsertUpdate</type> - <description/> - <distribute>Y</distribute> - <custom_distribution/> - <copies>1</copies> - <partitioning> - <method>none</method> - <schema_name/> - </partitioning> - <connection>erp indoteknik production (localhost)</connection> - <commit>100</commit> - <update_bypassed>N</update_bypassed> - <lookup> - <schema>public</schema> - <table>product_template</table> - <key> - <name>template_id</name> - <field>id</field> - <condition>=</condition> - <name2/> - </key> - <value> - <name>solr_flag</name> - <rename>solr_flag</rename> - <update>Y</update> - </value> - </lookup> - <attributes/> - <cluster_schema/> - <remotesteps> - <input> - </input> - <output> - </output> - </remotesteps> - <GUI> - <xloc>928</xloc> - <yloc>272</yloc> - <draw>Y</draw> - </GUI> - </step> - <step> - <name>pl1 solr flag pp</name> - <type>InsertUpdate</type> - <description/> - <distribute>Y</distribute> - <custom_distribution/> - <copies>1</copies> - <partitioning> - <method>none</method> - <schema_name/> - </partitioning> - <connection>erp indoteknik production (localhost)</connection> - <commit>100</commit> - <update_bypassed>N</update_bypassed> - <lookup> - <schema>public</schema> - <table>product_product</table> - <key> - <name>product_id</name> - <field>id</field> - <condition>=</condition> - <name2/> - </key> - <value> - <name>solr_flag</name> - <rename>solr_flag</rename> - <update>Y</update> - </value> - </lookup> - <attributes/> - <cluster_schema/> - <remotesteps> - <input> - </input> - <output> - </output> - </remotesteps> - <GUI> - <xloc>1120</xloc> - <yloc>272</yloc> - <draw>Y</draw> - </GUI> - </step> - <step> <name>Merge join</name> <type>MergeJoin</type> <description/> @@ -1060,6 +974,92 @@ </GUI> </step> <step> + <name>pl1 solr flag pp</name> + <type>InsertUpdate</type> + <description/> + <distribute>Y</distribute> + <custom_distribution/> + <copies>1</copies> + <partitioning> + <method>none</method> + <schema_name/> + </partitioning> + <connection>erp indoteknik production (localhost)</connection> + <commit>100</commit> + <update_bypassed>N</update_bypassed> + <lookup> + <schema>public</schema> + <table>product_product</table> + <key> + <name>product_id</name> + <field>id</field> + <condition>=</condition> + <name2/> + </key> + <value> + <name>solr_flag</name> + <rename>solr_flag</rename> + <update>Y</update> + </value> + </lookup> + <attributes/> + <cluster_schema/> + <remotesteps> + <input> + </input> + <output> + </output> + </remotesteps> + <GUI> + <xloc>1120</xloc> + <yloc>272</yloc> + <draw>Y</draw> + </GUI> + </step> + <step> + <name>pl1 solr flag pt</name> + <type>InsertUpdate</type> + <description/> + <distribute>Y</distribute> + <custom_distribution/> + <copies>1</copies> + <partitioning> + <method>none</method> + <schema_name/> + </partitioning> + <connection>erp indoteknik production (localhost)</connection> + <commit>100</commit> + <update_bypassed>N</update_bypassed> + <lookup> + <schema>public</schema> + <table>product_template</table> + <key> + <name>template_id</name> + <field>id</field> + <condition>=</condition> + <name2/> + </key> + <value> + <name>solr_flag</name> + <rename>solr_flag</rename> + <update>Y</update> + </value> + </lookup> + <attributes/> + <cluster_schema/> + <remotesteps> + <input> + </input> + <output> + </output> + </remotesteps> + <GUI> + <xloc>928</xloc> + <yloc>272</yloc> + <draw>Y</draw> + </GUI> + </step> + <step> <name>price compute</name> <type>TableInput</type> <description/> diff --git a/insert_update_pricelist2.ktr b/insert_update_pricelist2.ktr index 10bf73c..461b15c 100644 --- a/insert_update_pricelist2.ktr +++ b/insert_update_pricelist2.ktr @@ -572,12 +572,12 @@ <hop> <from>p Insert / update tier2</from> <to>pl2 solr flag pt</to> - <enabled>Y</enabled> + <enabled>N</enabled> </hop> <hop> <from>pl2 solr flag pt</from> <to>pl2 solr flag pp</to> - <enabled>Y</enabled> + <enabled>N</enabled> </hop> </order> <step> @@ -799,92 +799,6 @@ </GUI> </step> <step> - <name>pl2 solr flag pt</name> - <type>InsertUpdate</type> - <description/> - <distribute>Y</distribute> - <custom_distribution/> - <copies>1</copies> - <partitioning> - <method>none</method> - <schema_name/> - </partitioning> - <connection>erp indoteknik production (localhost)</connection> - <commit>100</commit> - <update_bypassed>N</update_bypassed> - <lookup> - <schema>public</schema> - <table>product_template</table> - <key> - <name>template_id</name> - <field>id</field> - <condition>=</condition> - <name2/> - </key> - <value> - <name>solr_flag</name> - <rename>solr_flag</rename> - <update>Y</update> - </value> - </lookup> - <attributes/> - <cluster_schema/> - <remotesteps> - <input> - </input> - <output> - </output> - </remotesteps> - <GUI> - <xloc>912</xloc> - <yloc>272</yloc> - <draw>Y</draw> - </GUI> - </step> - <step> - <name>pl2 solr flag pp</name> - <type>InsertUpdate</type> - <description/> - <distribute>Y</distribute> - <custom_distribution/> - <copies>1</copies> - <partitioning> - <method>none</method> - <schema_name/> - </partitioning> - <connection>erp indoteknik production (localhost)</connection> - <commit>100</commit> - <update_bypassed>N</update_bypassed> - <lookup> - <schema>public</schema> - <table>product_product</table> - <key> - <name>product_id</name> - <field>id</field> - <condition>=</condition> - <name2/> - </key> - <value> - <name>solr_flag</name> - <rename>solr_flag</rename> - <update>Y</update> - </value> - </lookup> - <attributes/> - <cluster_schema/> - <remotesteps> - <input> - </input> - <output> - </output> - </remotesteps> - <GUI> - <xloc>1088</xloc> - <yloc>272</yloc> - <draw>Y</draw> - </GUI> - </step> - <step> <name>Merge join</name> <type>MergeJoin</type> <description/> @@ -1060,6 +974,92 @@ </GUI> </step> <step> + <name>pl2 solr flag pp</name> + <type>InsertUpdate</type> + <description/> + <distribute>Y</distribute> + <custom_distribution/> + <copies>1</copies> + <partitioning> + <method>none</method> + <schema_name/> + </partitioning> + <connection>erp indoteknik production (localhost)</connection> + <commit>100</commit> + <update_bypassed>N</update_bypassed> + <lookup> + <schema>public</schema> + <table>product_product</table> + <key> + <name>product_id</name> + <field>id</field> + <condition>=</condition> + <name2/> + </key> + <value> + <name>solr_flag</name> + <rename>solr_flag</rename> + <update>Y</update> + </value> + </lookup> + <attributes/> + <cluster_schema/> + <remotesteps> + <input> + </input> + <output> + </output> + </remotesteps> + <GUI> + <xloc>1088</xloc> + <yloc>272</yloc> + <draw>Y</draw> + </GUI> + </step> + <step> + <name>pl2 solr flag pt</name> + <type>InsertUpdate</type> + <description/> + <distribute>Y</distribute> + <custom_distribution/> + <copies>1</copies> + <partitioning> + <method>none</method> + <schema_name/> + </partitioning> + <connection>erp indoteknik production (localhost)</connection> + <commit>100</commit> + <update_bypassed>N</update_bypassed> + <lookup> + <schema>public</schema> + <table>product_template</table> + <key> + <name>template_id</name> + <field>id</field> + <condition>=</condition> + <name2/> + </key> + <value> + <name>solr_flag</name> + <rename>solr_flag</rename> + <update>Y</update> + </value> + </lookup> + <attributes/> + <cluster_schema/> + <remotesteps> + <input> + </input> + <output> + </output> + </remotesteps> + <GUI> + <xloc>912</xloc> + <yloc>272</yloc> + <draw>Y</draw> + </GUI> + </step> + <step> <name>price compute</name> <type>TableInput</type> <description/> diff --git a/insert_update_pricelist3.ktr b/insert_update_pricelist3.ktr index ec3e954..e1cc183 100644 --- a/insert_update_pricelist3.ktr +++ b/insert_update_pricelist3.ktr @@ -572,12 +572,12 @@ <hop> <from>p Insert / update tier3</from> <to>pl3 solr flag pt</to> - <enabled>Y</enabled> + <enabled>N</enabled> </hop> <hop> <from>pl3 solr flag pt</from> <to>pl3 solr flag pp</to> - <enabled>Y</enabled> + <enabled>N</enabled> </hop> </order> <step> @@ -799,92 +799,6 @@ </GUI> </step> <step> - <name>pl3 solr flag pt</name> - <type>InsertUpdate</type> - <description/> - <distribute>Y</distribute> - <custom_distribution/> - <copies>1</copies> - <partitioning> - <method>none</method> - <schema_name/> - </partitioning> - <connection>erp indoteknik production (localhost)</connection> - <commit>100</commit> - <update_bypassed>N</update_bypassed> - <lookup> - <schema>public</schema> - <table>product_template</table> - <key> - <name>template_id</name> - <field>id</field> - <condition>=</condition> - <name2/> - </key> - <value> - <name>solr_flag</name> - <rename>solr_flag</rename> - <update>Y</update> - </value> - </lookup> - <attributes/> - <cluster_schema/> - <remotesteps> - <input> - </input> - <output> - </output> - </remotesteps> - <GUI> - <xloc>912</xloc> - <yloc>272</yloc> - <draw>Y</draw> - </GUI> - </step> - <step> - <name>pl3 solr flag pp</name> - <type>InsertUpdate</type> - <description/> - <distribute>Y</distribute> - <custom_distribution/> - <copies>1</copies> - <partitioning> - <method>none</method> - <schema_name/> - </partitioning> - <connection>erp indoteknik production (localhost)</connection> - <commit>100</commit> - <update_bypassed>N</update_bypassed> - <lookup> - <schema>public</schema> - <table>product_product</table> - <key> - <name>product_id</name> - <field>id</field> - <condition>=</condition> - <name2/> - </key> - <value> - <name>solr_flag</name> - <rename>solr_flag</rename> - <update>Y</update> - </value> - </lookup> - <attributes/> - <cluster_schema/> - <remotesteps> - <input> - </input> - <output> - </output> - </remotesteps> - <GUI> - <xloc>1088</xloc> - <yloc>272</yloc> - <draw>Y</draw> - </GUI> - </step> - <step> <name>Merge join</name> <type>MergeJoin</type> <description/> @@ -1060,6 +974,92 @@ </GUI> </step> <step> + <name>pl3 solr flag pp</name> + <type>InsertUpdate</type> + <description/> + <distribute>Y</distribute> + <custom_distribution/> + <copies>1</copies> + <partitioning> + <method>none</method> + <schema_name/> + </partitioning> + <connection>erp indoteknik production (localhost)</connection> + <commit>100</commit> + <update_bypassed>N</update_bypassed> + <lookup> + <schema>public</schema> + <table>product_product</table> + <key> + <name>product_id</name> + <field>id</field> + <condition>=</condition> + <name2/> + </key> + <value> + <name>solr_flag</name> + <rename>solr_flag</rename> + <update>Y</update> + </value> + </lookup> + <attributes/> + <cluster_schema/> + <remotesteps> + <input> + </input> + <output> + </output> + </remotesteps> + <GUI> + <xloc>1088</xloc> + <yloc>272</yloc> + <draw>Y</draw> + </GUI> + </step> + <step> + <name>pl3 solr flag pt</name> + <type>InsertUpdate</type> + <description/> + <distribute>Y</distribute> + <custom_distribution/> + <copies>1</copies> + <partitioning> + <method>none</method> + <schema_name/> + </partitioning> + <connection>erp indoteknik production (localhost)</connection> + <commit>100</commit> + <update_bypassed>N</update_bypassed> + <lookup> + <schema>public</schema> + <table>product_template</table> + <key> + <name>template_id</name> + <field>id</field> + <condition>=</condition> + <name2/> + </key> + <value> + <name>solr_flag</name> + <rename>solr_flag</rename> + <update>Y</update> + </value> + </lookup> + <attributes/> + <cluster_schema/> + <remotesteps> + <input> + </input> + <output> + </output> + </remotesteps> + <GUI> + <xloc>912</xloc> + <yloc>272</yloc> + <draw>Y</draw> + </GUI> + </step> + <step> <name>price compute</name> <type>TableInput</type> <description/> diff --git a/insert_update_pricelist4.ktr b/insert_update_pricelist4.ktr index f8d75e6..79f9d0e 100644 --- a/insert_update_pricelist4.ktr +++ b/insert_update_pricelist4.ktr @@ -572,12 +572,12 @@ <hop> <from>p Insert / update tier4</from> <to>pl4 solr flag pt</to> - <enabled>Y</enabled> + <enabled>N</enabled> </hop> <hop> <from>pl4 solr flag pt</from> <to>pl4 solr flag pp</to> - <enabled>Y</enabled> + <enabled>N</enabled> </hop> </order> <step> @@ -799,92 +799,6 @@ </GUI> </step> <step> - <name>pl4 solr flag pt</name> - <type>InsertUpdate</type> - <description/> - <distribute>Y</distribute> - <custom_distribution/> - <copies>1</copies> - <partitioning> - <method>none</method> - <schema_name/> - </partitioning> - <connection>erp indoteknik production (localhost)</connection> - <commit>100</commit> - <update_bypassed>N</update_bypassed> - <lookup> - <schema>public</schema> - <table>product_template</table> - <key> - <name>template_id</name> - <field>id</field> - <condition>=</condition> - <name2/> - </key> - <value> - <name>solr_flag</name> - <rename>solr_flag</rename> - <update>Y</update> - </value> - </lookup> - <attributes/> - <cluster_schema/> - <remotesteps> - <input> - </input> - <output> - </output> - </remotesteps> - <GUI> - <xloc>912</xloc> - <yloc>272</yloc> - <draw>Y</draw> - </GUI> - </step> - <step> - <name>pl4 solr flag pp</name> - <type>InsertUpdate</type> - <description/> - <distribute>Y</distribute> - <custom_distribution/> - <copies>1</copies> - <partitioning> - <method>none</method> - <schema_name/> - </partitioning> - <connection>erp indoteknik production (localhost)</connection> - <commit>100</commit> - <update_bypassed>N</update_bypassed> - <lookup> - <schema>public</schema> - <table>product_product</table> - <key> - <name>product_id</name> - <field>id</field> - <condition>=</condition> - <name2/> - </key> - <value> - <name>solr_flag</name> - <rename>solr_flag</rename> - <update>Y</update> - </value> - </lookup> - <attributes/> - <cluster_schema/> - <remotesteps> - <input> - </input> - <output> - </output> - </remotesteps> - <GUI> - <xloc>1088</xloc> - <yloc>272</yloc> - <draw>Y</draw> - </GUI> - </step> - <step> <name>Merge join</name> <type>MergeJoin</type> <description/> @@ -1060,6 +974,92 @@ </GUI> </step> <step> + <name>pl4 solr flag pp</name> + <type>InsertUpdate</type> + <description/> + <distribute>Y</distribute> + <custom_distribution/> + <copies>1</copies> + <partitioning> + <method>none</method> + <schema_name/> + </partitioning> + <connection>erp indoteknik production (localhost)</connection> + <commit>100</commit> + <update_bypassed>N</update_bypassed> + <lookup> + <schema>public</schema> + <table>product_product</table> + <key> + <name>product_id</name> + <field>id</field> + <condition>=</condition> + <name2/> + </key> + <value> + <name>solr_flag</name> + <rename>solr_flag</rename> + <update>Y</update> + </value> + </lookup> + <attributes/> + <cluster_schema/> + <remotesteps> + <input> + </input> + <output> + </output> + </remotesteps> + <GUI> + <xloc>1088</xloc> + <yloc>272</yloc> + <draw>Y</draw> + </GUI> + </step> + <step> + <name>pl4 solr flag pt</name> + <type>InsertUpdate</type> + <description/> + <distribute>Y</distribute> + <custom_distribution/> + <copies>1</copies> + <partitioning> + <method>none</method> + <schema_name/> + </partitioning> + <connection>erp indoteknik production (localhost)</connection> + <commit>100</commit> + <update_bypassed>N</update_bypassed> + <lookup> + <schema>public</schema> + <table>product_template</table> + <key> + <name>template_id</name> + <field>id</field> + <condition>=</condition> + <name2/> + </key> + <value> + <name>solr_flag</name> + <rename>solr_flag</rename> + <update>Y</update> + </value> + </lookup> + <attributes/> + <cluster_schema/> + <remotesteps> + <input> + </input> + <output> + </output> + </remotesteps> + <GUI> + <xloc>912</xloc> + <yloc>272</yloc> + <draw>Y</draw> + </GUI> + </step> + <step> <name>price compute</name> <type>TableInput</type> <description/> diff --git a/insert_update_pricelist5.ktr b/insert_update_pricelist5.ktr index d06bd59..ae14135 100644 --- a/insert_update_pricelist5.ktr +++ b/insert_update_pricelist5.ktr @@ -572,12 +572,12 @@ <hop> <from>p Insert / update tier5</from> <to>pl5 solr flag pt</to> - <enabled>Y</enabled> + <enabled>N</enabled> </hop> <hop> <from>pl5 solr flag pt</from> <to>pl5 solr flag pp</to> - <enabled>Y</enabled> + <enabled>N</enabled> </hop> </order> <step> @@ -799,92 +799,6 @@ </GUI> </step> <step> - <name>pl5 solr flag pt</name> - <type>InsertUpdate</type> - <description/> - <distribute>Y</distribute> - <custom_distribution/> - <copies>1</copies> - <partitioning> - <method>none</method> - <schema_name/> - </partitioning> - <connection>erp indoteknik production (localhost)</connection> - <commit>100</commit> - <update_bypassed>N</update_bypassed> - <lookup> - <schema>public</schema> - <table>product_template</table> - <key> - <name>template_id</name> - <field>id</field> - <condition>=</condition> - <name2/> - </key> - <value> - <name>solr_flag</name> - <rename>solr_flag</rename> - <update>Y</update> - </value> - </lookup> - <attributes/> - <cluster_schema/> - <remotesteps> - <input> - </input> - <output> - </output> - </remotesteps> - <GUI> - <xloc>912</xloc> - <yloc>272</yloc> - <draw>Y</draw> - </GUI> - </step> - <step> - <name>pl5 solr flag pp</name> - <type>InsertUpdate</type> - <description/> - <distribute>Y</distribute> - <custom_distribution/> - <copies>1</copies> - <partitioning> - <method>none</method> - <schema_name/> - </partitioning> - <connection>erp indoteknik production (localhost)</connection> - <commit>100</commit> - <update_bypassed>N</update_bypassed> - <lookup> - <schema>public</schema> - <table>product_product</table> - <key> - <name>product_id</name> - <field>id</field> - <condition>=</condition> - <name2/> - </key> - <value> - <name>solr_flag</name> - <rename>solr_flag</rename> - <update>Y</update> - </value> - </lookup> - <attributes/> - <cluster_schema/> - <remotesteps> - <input> - </input> - <output> - </output> - </remotesteps> - <GUI> - <xloc>1088</xloc> - <yloc>272</yloc> - <draw>Y</draw> - </GUI> - </step> - <step> <name>Merge join</name> <type>MergeJoin</type> <description/> @@ -1060,6 +974,92 @@ </GUI> </step> <step> + <name>pl5 solr flag pp</name> + <type>InsertUpdate</type> + <description/> + <distribute>Y</distribute> + <custom_distribution/> + <copies>1</copies> + <partitioning> + <method>none</method> + <schema_name/> + </partitioning> + <connection>erp indoteknik production (localhost)</connection> + <commit>100</commit> + <update_bypassed>N</update_bypassed> + <lookup> + <schema>public</schema> + <table>product_product</table> + <key> + <name>product_id</name> + <field>id</field> + <condition>=</condition> + <name2/> + </key> + <value> + <name>solr_flag</name> + <rename>solr_flag</rename> + <update>Y</update> + </value> + </lookup> + <attributes/> + <cluster_schema/> + <remotesteps> + <input> + </input> + <output> + </output> + </remotesteps> + <GUI> + <xloc>1088</xloc> + <yloc>272</yloc> + <draw>Y</draw> + </GUI> + </step> + <step> + <name>pl5 solr flag pt</name> + <type>InsertUpdate</type> + <description/> + <distribute>Y</distribute> + <custom_distribution/> + <copies>1</copies> + <partitioning> + <method>none</method> + <schema_name/> + </partitioning> + <connection>erp indoteknik production (localhost)</connection> + <commit>100</commit> + <update_bypassed>N</update_bypassed> + <lookup> + <schema>public</schema> + <table>product_template</table> + <key> + <name>template_id</name> + <field>id</field> + <condition>=</condition> + <name2/> + </key> + <value> + <name>solr_flag</name> + <rename>solr_flag</rename> + <update>Y</update> + </value> + </lookup> + <attributes/> + <cluster_schema/> + <remotesteps> + <input> + </input> + <output> + </output> + </remotesteps> + <GUI> + <xloc>912</xloc> + <yloc>272</yloc> + <draw>Y</draw> + </GUI> + </step> + <step> <name>price compute</name> <type>TableInput</type> <description/> |