Subversion Repositories SmartDukaan

    <name>PhysicalOrder</name>

    <type>TableInput</type>

    <description>PhysicalOrder</description>

    <distribute>Y</distribute>

    <copies>1</copies>

         <partitioning>

           <method>none</method>

           <schema_name/>

           </partitioning>

    <connection>Prod_trans</connection>

    <sql>select o.id as orderId, 

o.customer_id as userId, 

0 as orderType, 

case when o.originalOrderId is null then datediff(o.created_timestamp, '20101231')

	else datediff((select created_timestamp from `order` where id = o.originalOrderId), '20101231') end as dateId ,

o.created_timestamp as timestamp, 

0 as repeatType, 

0 as repeatFrequency, 

o.transaction_id as transactionId, 

case when total_amount<250 then 0 when total_amount<500 then 1 when total_amount<1000 then 2 

			 when total_amount<2000 then 3 when total_amount < 5000 then 4 when total_amount < 10000 then 5 when total_amount < 15000 then 6 

			 when total_amount <20000 then 7 when total_amount < 50000 then 8 else 9 end as amount, 

case when l.transfer_price<250 then 0 when l.transfer_price<500 then 1 when l.transfer_price<1000 then 2 

			 when l.transfer_price<2000 then 3 when l.transfer_price < 5000 then 4 when l.transfer_price < 10000 then 5 when l.transfer_price < 15000 then 6 

			 when l.transfer_price <20000 then 7 when l.transfer_price < 50000 then 8 else 9 end as transferPrice, 

o.customer_pincode as pincode, 

l.item_id as itemId, 

l.quantity ,

o.status,

0 as firstOrderType,

0 as firstOrderDate 

from `order` o 

join lineitem l on l.order_id = o.id 

where o.status in(2,3,4,5,6,7,9,10,12,13,14,16,17,19,20,21,22,23,24,25,26,27,31,32,33,35,36,37,38,39,40,41,42,43,44,45,46,48,50,51,52,54,56,57,58,59,60,61,62,63,64,65,66,67,68,70,72,74,76,77,79,80,81)

</sql>

    <limit>0</limit>

    <lookup/>

    <execute_each_row>N</execute_each_row>

    <variables_active>N</variables_active>

    <lazy_conversion_active>N</lazy_conversion_active>

     <cluster_schema/>

 <remotesteps>   <input>   </input>   <output>   </output> </remotesteps>    <GUI>

      <xloc>126</xloc>

      <yloc>145</yloc>

      <draw>Y</draw>

      </GUI>

    </step>

  <step>

    <type>SortRows</type>

    <description/>

    <distribute>Y</distribute>

    <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>25</free_memory>

      <compress>N</compress>

      <compress_variable/>

      <unique_rows>N</unique_rows>

    <fields>

      <field>

        <name>userId</name>

        <ascending>Y</ascending>

        <case_sensitive>N</case_sensitive>

      </field>

    </fields>

     <cluster_schema/>

 <remotesteps>   <input>   </input>   <output>   </output> </remotesteps>    <GUI>

      <xloc>566</xloc>

      <yloc>209</yloc>

      <draw>Y</draw>

      </GUI>

    </step>

  <step>

    <name>Table output</name>

    <schema>sales</schema>

    <table>commonorders</table>

    <commit>1000</commit>

    <truncate>Y</truncate>

    <specify_fields>N</specify_fields>

    <partitioning_enabled>N</partitioning_enabled>

    <partitioning_field/>

    <partitioning_daily>N</partitioning_daily>

    <partitioning_monthly>Y</partitioning_monthly>

    <tablename_in_field>N</tablename_in_field>

    <tablename_field/>

    <tablename_in_table>Y</tablename_in_table>

    <return_keys>N</return_keys>

    <fields>

        <field>

          <column_name>userId</column_name>

          <stream_name>userId</stream_name>

        </field>

        <field>

          <column_name>amount</column_name>

        </field>

        <field>

          <column_name>orderId</column_name>

        </field>

        <field>

          <column_name>dateId</column_name>

        </field>

        <field>

        </field>

        <field>

        </field>

        <field>

          <column_name>transferPrice</column_name>

          <stream_name>transferPrice</stream_name>

          <column_name>pincode</column_name>

          <stream_name>pincode</stream_name>

          <column_name>itemId</column_name>

        <field>

          <column_name>quantity</column_name>

          <stream_name>quantity</stream_name>

          <column_name>status</column_name>

        </field>

        <field>

          <column_name>firstOrderType</column_name>

        </field>

        <field>

          <column_name>firstOrderDate</column_name>

        </field>

    </fields>