Subversion Repositories SmartDukaan

Rev

Rev 6547 | Rev 6557 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
6541 anupam.sin 1
<?xml version="1.0" encoding="UTF-8"?>
2
<transformation>
3
  <info>
4
    <name>RepeatSaleAnalysis</name>
5
    <description/>
6
    <extended_description/>
7
    <trans_version/>
8
    <trans_type>Normal</trans_type>
9
    <directory>&#47;</directory>
10
    <parameters>
11
    </parameters>
12
    <log>
13
<trans-log-table><connection/>
14
<schema/>
15
<table/>
16
<size_limit_lines/>
17
<interval/>
18
<timeout_days/>
19
<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>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>Y</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>Y</enabled><name>LOG_FIELD</name></field></trans-log-table>
20
<perf-log-table><connection/>
21
<schema/>
22
<table/>
23
<interval/>
24
<timeout_days/>
25
<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>
26
<channel-log-table><connection/>
27
<schema/>
28
<table/>
29
<timeout_days/>
30
<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>
31
<step-log-table><connection/>
32
<schema/>
33
<table/>
34
<timeout_days/>
35
<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></step-log-table>
36
    </log>
37
    <maxdate>
38
      <connection/>
39
      <table/>
40
      <field/>
41
      <offset>0.0</offset>
42
      <maxdiff>0.0</maxdiff>
43
    </maxdate>
44
    <size_rowset>10000</size_rowset>
45
    <sleep_time_empty>50</sleep_time_empty>
46
    <sleep_time_full>50</sleep_time_full>
47
    <unique_connections>N</unique_connections>
48
    <feedback_shown>Y</feedback_shown>
49
    <feedback_size>50000</feedback_size>
50
    <using_thread_priorities>Y</using_thread_priorities>
51
    <shared_objects_file/>
52
    <capture_step_performance>N</capture_step_performance>
53
    <step_performance_capturing_delay>1000</step_performance_capturing_delay>
54
    <step_performance_capturing_size_limit>100</step_performance_capturing_size_limit>
55
    <dependencies>
56
    </dependencies>
57
    <partitionschemas>
58
    </partitionschemas>
59
    <slaveservers>
60
    </slaveservers>
61
    <clusterschemas>
62
    </clusterschemas>
63
  <created_user>-</created_user>
64
  <created_date>2012&#47;12&#47;21 13:18:30.424</created_date>
65
  <modified_user>-</modified_user>
66
  <modified_date>2012&#47;12&#47;21 13:18:30.424</modified_date>
67
  </info>
68
  <notepads>
69
  </notepads>
70
  <connection>
71
    <name>local_tran</name>
72
    <server>localhost</server>
73
    <type>MYSQL</type>
74
    <access>Native</access>
75
    <database>transaction</database>
76
    <port>3306</port>
77
    <username>root</username>
78
    <password>Encrypted 2be98afc86aa7f2e4b811a1608cc2fd8a</password>
79
    <servername/>
80
    <data_tablespace/>
81
    <index_tablespace/>
82
    <attributes>
83
      <attribute><code>EXTRA_OPTION_MYSQL.defaultFetchSize</code><attribute>500</attribute></attribute>
84
      <attribute><code>EXTRA_OPTION_MYSQL.useCursorFetch</code><attribute>true</attribute></attribute>
85
      <attribute><code>FORCE_IDENTIFIERS_TO_LOWERCASE</code><attribute>N</attribute></attribute>
86
      <attribute><code>FORCE_IDENTIFIERS_TO_UPPERCASE</code><attribute>N</attribute></attribute>
87
      <attribute><code>IS_CLUSTERED</code><attribute>N</attribute></attribute>
88
      <attribute><code>PORT_NUMBER</code><attribute>3306</attribute></attribute>
89
      <attribute><code>QUOTE_ALL_FIELDS</code><attribute>N</attribute></attribute>
90
      <attribute><code>STREAM_RESULTS</code><attribute>Y</attribute></attribute>
91
      <attribute><code>SUPPORTS_BOOLEAN_DATA_TYPE</code><attribute>N</attribute></attribute>
92
      <attribute><code>USE_POOLING</code><attribute>N</attribute></attribute>
93
    </attributes>
94
  </connection>
95
  <connection>
96
    <name>sales_local</name>
97
    <server>localhost</server>
98
    <type>MYSQL</type>
99
    <access>Native</access>
100
    <database>sales</database>
101
    <port>3306</port>
102
    <username>root</username>
103
    <password>Encrypted 2be98afc86aa7f2e4b811a1608cc2fd8a</password>
104
    <servername/>
105
    <data_tablespace/>
106
    <index_tablespace/>
107
    <attributes>
108
      <attribute><code>EXTRA_OPTION_MYSQL.defaultFetchSize</code><attribute>500</attribute></attribute>
109
      <attribute><code>EXTRA_OPTION_MYSQL.useCursorFetch</code><attribute>true</attribute></attribute>
110
      <attribute><code>FORCE_IDENTIFIERS_TO_LOWERCASE</code><attribute>N</attribute></attribute>
111
      <attribute><code>FORCE_IDENTIFIERS_TO_UPPERCASE</code><attribute>N</attribute></attribute>
112
      <attribute><code>IS_CLUSTERED</code><attribute>N</attribute></attribute>
113
      <attribute><code>PORT_NUMBER</code><attribute>3306</attribute></attribute>
114
      <attribute><code>QUOTE_ALL_FIELDS</code><attribute>N</attribute></attribute>
115
      <attribute><code>STREAM_RESULTS</code><attribute>Y</attribute></attribute>
116
      <attribute><code>SUPPORTS_BOOLEAN_DATA_TYPE</code><attribute>N</attribute></attribute>
117
      <attribute><code>USE_POOLING</code><attribute>N</attribute></attribute>
118
    </attributes>
119
  </connection>
120
  <order>
6554 anupam.sin 121
  <hop> <from>PhysicalOrder</from><to>PhysicalOrderSelector</to><enabled>Y</enabled> </hop>  <hop> <from>Append streams</from><to>Sort rows</to><enabled>Y</enabled> </hop>  <hop> <from>Sort rows</from><to>Table output</to><enabled>Y</enabled> </hop>  <hop> <from>DigitalOrder</from><to>DigitalOrderSelector</to><enabled>Y</enabled> </hop>  <hop> <from>DigitalOrderSelector</from><to>Append streams</to><enabled>Y</enabled> </hop>  <hop> <from>PhysicalOrderSelector</from><to>Append streams</to><enabled>Y</enabled> </hop>  </order>
6541 anupam.sin 122
  <step>
123
    <name>Append streams</name>
124
    <type>Append</type>
125
    <description/>
126
    <distribute>Y</distribute>
127
    <copies>1</copies>
128
         <partitioning>
129
           <method>none</method>
130
           <schema_name/>
131
           </partitioning>
6554 anupam.sin 132
<head_name>PhysicalOrderSelector</head_name>
133
<tail_name>DigitalOrderSelector</tail_name>
6541 anupam.sin 134
     <cluster_schema/>
135
 <remotesteps>   <input>   </input>   <output>   </output> </remotesteps>    <GUI>
6554 anupam.sin 136
      <xloc>463</xloc>
137
      <yloc>209</yloc>
6541 anupam.sin 138
      <draw>Y</draw>
139
      </GUI>
140
    </step>
141
 
142
  <step>
143
    <name>DigitalOrder</name>
144
    <type>TableInput</type>
145
    <description/>
146
    <distribute>Y</distribute>
147
    <copies>1</copies>
148
         <partitioning>
149
           <method>none</method>
150
           <schema_name/>
151
           </partitioning>
152
    <connection>local_tran</connection>
6547 anupam.sin 153
    <sql>select b.id as orderId, 
154
b.userId, 
155
1 as orderType, 
156
datediff(b.creationTimestamp, &apos;20101231&apos;) as dateId,
157
 
158
 
159
b.transaction_id as transactionId, 
6554 anupam.sin 160
case when b.totalAmount&lt;250 then 0 when b.totalAmount&lt;500 then 1 when b.totalAmount&lt;1000 then 2 
161
			 when b.totalAmount&lt;2000 then 3 when b.totalAmount &lt; 5000 then 4 when b.totalAmount &lt; 10000 then 5 when b.totalAmount &lt; 15000 then 6 
162
			 when b.totalAmount &lt;20000 then 7 when b.totalAmount &lt; 50000 then 8 else 9 end as amount,
163
case when b.totalAmount&lt;250 then 0 when b.totalAmount&lt;500 then 1 when b.totalAmount&lt;1000 then 2 
164
			 when b.totalAmount&lt;2000 then 3 when b.totalAmount &lt; 5000 then 4 when b.totalAmount &lt; 10000 then 5 when b.totalAmount &lt; 15000 then 6 
165
			 when b.totalAmount &lt;20000 then 7 when b.totalAmount &lt; 50000 then 8 else 9 end as transferPrice, 
166
&apos;000000&apos; as pincode, 
167
case when d.dthOperatorId is null then 100000 + m.mobileOperatorId else 100000 + d.dthOperatorId end as itemId, 
6547 anupam.sin 168
1 as quantity,
169
1005 as status,
170
 
171
 
172
from baseorder b 
173
join rechargeorder r on b.id = r.immediateconsumedorder_digitalorder_baseorder_id 
6554 anupam.sin 174
left join mobilerechargeorder m on m.rechargeorder_immediateconsumedorder_digitalorder_baseorder_id = b.id 
175
left join dthrechargeorder d on d.rechargeorder_immediateconsumedorder_digitalorder_baseorder_id = b.id 
6547 anupam.sin 176
where r.status = 5;
177
</sql>
6541 anupam.sin 178
    <limit>0</limit>
179
    <lookup/>
180
    <execute_each_row>N</execute_each_row>
181
    <variables_active>N</variables_active>
182
    <lazy_conversion_active>N</lazy_conversion_active>
183
     <cluster_schema/>
184
 <remotesteps>   <input>   </input>   <output>   </output> </remotesteps>    <GUI>
6554 anupam.sin 185
      <xloc>119</xloc>
186
      <yloc>273</yloc>
6541 anupam.sin 187
      <draw>Y</draw>
188
      </GUI>
189
    </step>
190
 
191
  <step>
192
    <name>PhysicalOrder</name>
193
    <type>TableInput</type>
194
    <description>PhysicalOrder</description>
195
    <distribute>Y</distribute>
196
    <copies>1</copies>
197
         <partitioning>
198
           <method>none</method>
199
           <schema_name/>
200
           </partitioning>
201
    <connection>local_tran</connection>
202
    <sql>select o.id as orderId, 
203
o.customer_id as userId, 
204
 
205
case when o.originalOrderId is null then datediff(o.created_timestamp, &apos;20101231&apos;)
6547 anupam.sin 206
	else datediff((select created_timestamp from `order` where id = o.originalOrderId), &apos;20101231&apos;) end as dateId , 
6541 anupam.sin 207
 
208
 
209
o.transaction_id as transactionId, 
6554 anupam.sin 210
case when total_amount&lt;250 then 0 when total_amount&lt;500 then 1 when total_amount&lt;1000 then 2 
211
			 when total_amount&lt;2000 then 3 when total_amount &lt; 5000 then 4 when total_amount &lt; 10000 then 5 when total_amount &lt; 15000 then 6 
212
			 when total_amount &lt;20000 then 7 when total_amount &lt; 50000 then 8 else 9 end as amount, 
213
case when l.transfer_price&lt;250 then 0 when l.transfer_price&lt;500 then 1 when l.transfer_price&lt;1000 then 2 
214
			 when l.transfer_price&lt;2000 then 3 when l.transfer_price &lt; 5000 then 4 when l.transfer_price &lt; 10000 then 5 when l.transfer_price &lt; 15000 then 6 
215
			 when l.transfer_price &lt;20000 then 7 when l.transfer_price &lt; 50000 then 8 else 9 end as transferPrice, 
6547 anupam.sin 216
o.customer_pincode as pincode, 
6541 anupam.sin 217
l.item_id as itemId, 
218
l.quantity ,
219
o.status,
220
 
221
 
222
from `order` o 
223
join lineitem l on l.order_id = o.id 
224
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)
225
</sql>
226
    <limit>0</limit>
227
    <lookup/>
228
    <execute_each_row>N</execute_each_row>
229
    <variables_active>N</variables_active>
230
    <lazy_conversion_active>N</lazy_conversion_active>
231
     <cluster_schema/>
232
 <remotesteps>   <input>   </input>   <output>   </output> </remotesteps>    <GUI>
6554 anupam.sin 233
      <xloc>126</xloc>
234
      <yloc>140</yloc>
6541 anupam.sin 235
      <draw>Y</draw>
236
      </GUI>
237
    </step>
238
 
239
  <step>
6554 anupam.sin 240
    <name>DigitalOrderSelector</name>
6541 anupam.sin 241
    <type>SelectValues</type>
242
    <description/>
243
    <distribute>Y</distribute>
244
    <copies>1</copies>
245
         <partitioning>
246
           <method>none</method>
247
           <schema_name/>
248
           </partitioning>
249
    <fields>        <select_unspecified>N</select_unspecified>
250
      <meta>        <name>orderId</name>
251
        <rename>orderId</rename>
252
        <type>-</type>
253
        <length>9</length>
254
        <precision>0</precision>
255
        <conversion_mask/>
256
        <date_format_lenient>false</date_format_lenient>
257
        <encoding/>
258
        <decimal_symbol/>
259
        <grouping_symbol/>
260
        <currency_symbol/>
261
        <storage_type/>
6547 anupam.sin 262
      </meta>      <meta>        <name>userId</name>
263
        <rename>userId</rename>
264
        <type>-</type>
265
        <length>9</length>
266
        <precision>0</precision>
267
        <conversion_mask/>
268
        <date_format_lenient>false</date_format_lenient>
269
        <encoding/>
270
        <decimal_symbol/>
271
        <grouping_symbol/>
272
        <currency_symbol/>
273
        <storage_type/>
274
      </meta>      <meta>        <name>orderType</name>
275
        <rename>orderType</rename>
276
        <type>-</type>
277
        <length>15</length>
278
        <precision>0</precision>
279
        <conversion_mask/>
280
        <date_format_lenient>false</date_format_lenient>
281
        <encoding/>
282
        <decimal_symbol/>
283
        <grouping_symbol/>
284
        <currency_symbol/>
285
        <storage_type/>
6541 anupam.sin 286
      </meta>      <meta>        <name>dateId</name>
287
        <rename>dateId</rename>
288
        <type>-</type>
289
        <length>15</length>
290
        <precision>0</precision>
291
        <conversion_mask/>
292
        <date_format_lenient>false</date_format_lenient>
293
        <encoding/>
294
        <decimal_symbol/>
295
        <grouping_symbol/>
296
        <currency_symbol/>
297
        <storage_type/>
6547 anupam.sin 298
      </meta>      <meta>        <name>repeatType</name>
299
        <rename>repeatType</rename>
6541 anupam.sin 300
        <type>-</type>
6547 anupam.sin 301
        <length>15</length>
6541 anupam.sin 302
        <precision>0</precision>
303
        <conversion_mask/>
304
        <date_format_lenient>false</date_format_lenient>
305
        <encoding/>
306
        <decimal_symbol/>
307
        <grouping_symbol/>
308
        <currency_symbol/>
309
        <storage_type/>
6547 anupam.sin 310
      </meta>      <meta>        <name>repeatFrequency</name>
311
        <rename>repeatFrequency</rename>
6541 anupam.sin 312
        <type>-</type>
313
        <length>15</length>
314
        <precision>0</precision>
315
        <conversion_mask/>
316
        <date_format_lenient>false</date_format_lenient>
317
        <encoding/>
318
        <decimal_symbol/>
319
        <grouping_symbol/>
320
        <currency_symbol/>
321
        <storage_type/>
6547 anupam.sin 322
      </meta>      <meta>        <name>transactionId</name>
323
        <rename>transactionId</rename>
324
        <type>-</type>
325
        <length>9</length>
326
        <precision>0</precision>
327
        <conversion_mask/>
328
        <date_format_lenient>false</date_format_lenient>
329
        <encoding/>
330
        <decimal_symbol/>
331
        <grouping_symbol/>
332
        <currency_symbol/>
333
        <storage_type/>
6541 anupam.sin 334
      </meta>      <meta>        <name>amount</name>
335
        <rename>amount</rename>
336
        <type>Number</type>
337
        <length>9</length>
338
        <precision>0</precision>
339
        <conversion_mask/>
340
        <date_format_lenient>false</date_format_lenient>
341
        <encoding/>
342
        <decimal_symbol/>
343
        <grouping_symbol/>
344
        <currency_symbol/>
345
        <storage_type/>
6547 anupam.sin 346
      </meta>      <meta>        <name>transferPrice</name>
347
        <rename>transferPrice</rename>
348
        <type>Number</type>
349
        <length>9</length>
350
        <precision>0</precision>
351
        <conversion_mask/>
352
        <date_format_lenient>false</date_format_lenient>
353
        <encoding/>
354
        <decimal_symbol/>
355
        <grouping_symbol/>
356
        <currency_symbol/>
357
        <storage_type/>
358
      </meta>      <meta>        <name>pincode</name>
359
        <rename>pincode</rename>
360
        <type>-</type>
361
        <length>3</length>
362
        <precision>-2</precision>
363
        <conversion_mask/>
364
        <date_format_lenient>false</date_format_lenient>
365
        <encoding/>
366
        <decimal_symbol/>
367
        <grouping_symbol/>
368
        <currency_symbol/>
369
        <storage_type/>
370
      </meta>      <meta>        <name>itemId</name>
371
        <rename>itemId</rename>
6554 anupam.sin 372
        <type>Integer</type>
373
        <length>9</length>
6547 anupam.sin 374
        <precision>0</precision>
375
        <conversion_mask/>
376
        <date_format_lenient>false</date_format_lenient>
377
        <encoding/>
378
        <decimal_symbol/>
379
        <grouping_symbol/>
380
        <currency_symbol/>
381
        <storage_type/>
382
      </meta>      <meta>        <name>quantity</name>
383
        <rename>quantity</rename>
384
        <type>Number</type>
385
        <length>15</length>
386
        <precision>0</precision>
387
        <conversion_mask/>
388
        <date_format_lenient>false</date_format_lenient>
389
        <encoding/>
390
        <decimal_symbol/>
391
        <grouping_symbol/>
392
        <currency_symbol/>
393
        <storage_type/>
394
      </meta>      <meta>        <name>status</name>
395
        <rename>status</rename>
396
        <type>-</type>
397
        <length>9</length>
398
        <precision>0</precision>
399
        <conversion_mask/>
400
        <date_format_lenient>false</date_format_lenient>
401
        <encoding/>
402
        <decimal_symbol/>
403
        <grouping_symbol/>
404
        <currency_symbol/>
405
        <storage_type/>
406
      </meta>      <meta>        <name>firstOrderType</name>
407
        <rename>firstOrderType</rename>
408
        <type>-</type>
409
        <length>15</length>
410
        <precision>0</precision>
411
        <conversion_mask/>
412
        <date_format_lenient>false</date_format_lenient>
413
        <encoding/>
414
        <decimal_symbol/>
415
        <grouping_symbol/>
416
        <currency_symbol/>
417
        <storage_type/>
418
      </meta>      <meta>        <name>firstOrderDate</name>
419
        <rename>firstOrderDate</rename>
420
        <type>-</type>
421
        <length>15</length>
422
        <precision>0</precision>
423
        <conversion_mask/>
424
        <date_format_lenient>false</date_format_lenient>
425
        <encoding/>
426
        <decimal_symbol/>
427
        <grouping_symbol/>
428
        <currency_symbol/>
429
        <storage_type/>
6541 anupam.sin 430
      </meta>    </fields>     <cluster_schema/>
431
 <remotesteps>   <input>   </input>   <output>   </output> </remotesteps>    <GUI>
432
      <xloc>316</xloc>
433
      <yloc>278</yloc>
434
      <draw>Y</draw>
435
      </GUI>
436
    </step>
437
 
438
  <step>
439
    <name>Sort rows</name>
440
    <type>SortRows</type>
441
    <description/>
442
    <distribute>Y</distribute>
443
    <copies>1</copies>
444
         <partitioning>
445
           <method>none</method>
446
           <schema_name/>
447
           </partitioning>
448
      <directory>%%java.io.tmpdir%%</directory>
449
      <prefix>out</prefix>
450
      <sort_size>1000000</sort_size>
451
      <free_memory>25</free_memory>
452
      <compress>N</compress>
453
      <compress_variable/>
454
      <unique_rows>N</unique_rows>
455
    <fields>
456
      <field>
457
        <name>userId</name>
458
        <ascending>Y</ascending>
459
        <case_sensitive>N</case_sensitive>
460
      </field>
461
    </fields>
462
     <cluster_schema/>
463
 <remotesteps>   <input>   </input>   <output>   </output> </remotesteps>    <GUI>
464
      <xloc>566</xloc>
465
      <yloc>209</yloc>
466
      <draw>Y</draw>
467
      </GUI>
468
    </step>
469
 
470
  <step>
471
    <name>Table output</name>
472
    <type>TableOutput</type>
473
    <description/>
474
    <distribute>Y</distribute>
475
    <copies>1</copies>
476
         <partitioning>
477
           <method>none</method>
478
           <schema_name/>
479
           </partitioning>
480
    <connection>sales_local</connection>
481
    <schema>sales</schema>
482
    <table>commonorders</table>
483
    <commit>1000</commit>
484
    <truncate>Y</truncate>
485
    <ignore_errors>N</ignore_errors>
486
    <use_batch>Y</use_batch>
487
    <specify_fields>N</specify_fields>
488
    <partitioning_enabled>N</partitioning_enabled>
489
    <partitioning_field/>
490
    <partitioning_daily>N</partitioning_daily>
491
    <partitioning_monthly>Y</partitioning_monthly>
492
    <tablename_in_field>N</tablename_in_field>
493
    <tablename_field/>
494
    <tablename_in_table>Y</tablename_in_table>
495
    <return_keys>N</return_keys>
496
    <return_field/>
497
    <fields>
498
        <field>
499
          <column_name>userId</column_name>
500
          <stream_name>userId</stream_name>
501
        </field>
502
        <field>
503
          <column_name>amount</column_name>
504
          <stream_name>amount</stream_name>
505
        </field>
506
        <field>
507
          <column_name>orderId</column_name>
508
          <stream_name>orderId</stream_name>
509
        </field>
510
        <field>
511
          <column_name>dateId</column_name>
512
          <stream_name>dateId</stream_name>
513
        </field>
514
        <field>
6547 anupam.sin 515
          <column_name>orderType</column_name>
516
          <stream_name>orderType</stream_name>
6541 anupam.sin 517
        </field>
6547 anupam.sin 518
        <field>
519
          <column_name>repeatType</column_name>
520
          <stream_name>repeatType</stream_name>
521
        </field>
522
        <field>
523
          <column_name>repeatFrequency</column_name>
524
          <stream_name>repeatFrequency</stream_name>
525
        </field>
526
        <field>
527
          <column_name>transactionId</column_name>
528
          <stream_name>transactionId</stream_name>
529
        </field>
530
        <field>
531
          <column_name>transferPrice</column_name>
532
          <stream_name>transferPrice</stream_name>
533
        </field>
534
        <field>
535
          <column_name>pincode</column_name>
536
          <stream_name>pincode</stream_name>
537
        </field>
538
        <field>
539
          <column_name>itemId</column_name>
540
          <stream_name>itemId</stream_name>
541
        </field>
542
        <field>
543
          <column_name>quantity</column_name>
544
          <stream_name>quantity</stream_name>
545
        </field>
546
        <field>
547
          <column_name>status</column_name>
548
          <stream_name>status</stream_name>
549
        </field>
550
        <field>
551
          <column_name>firstOrderType</column_name>
552
          <stream_name>firstOrderType</stream_name>
553
        </field>
554
        <field>
555
          <column_name>firstOrderDate</column_name>
556
          <stream_name>firstOrderDate</stream_name>
557
        </field>
6541 anupam.sin 558
    </fields>
559
     <cluster_schema/>
560
 <remotesteps>   <input>   </input>   <output>   </output> </remotesteps>    <GUI>
561
      <xloc>715</xloc>
562
      <yloc>209</yloc>
563
      <draw>Y</draw>
564
      </GUI>
565
    </step>
566
 
6554 anupam.sin 567
  <step>
568
    <name>PhysicalOrderSelector</name>
569
    <type>SelectValues</type>
570
    <description/>
571
    <distribute>Y</distribute>
572
    <copies>1</copies>
573
         <partitioning>
574
           <method>none</method>
575
           <schema_name/>
576
           </partitioning>
577
    <fields>        <select_unspecified>N</select_unspecified>
578
      <meta>        <name>orderId</name>
579
        <rename>orderId</rename>
580
        <type>-</type>
581
        <length>9</length>
582
        <precision>0</precision>
583
        <conversion_mask/>
584
        <date_format_lenient>false</date_format_lenient>
585
        <encoding/>
586
        <decimal_symbol/>
587
        <grouping_symbol/>
588
        <currency_symbol/>
589
        <storage_type/>
590
      </meta>      <meta>        <name>userId</name>
591
        <rename>userId</rename>
592
        <type>-</type>
593
        <length>9</length>
594
        <precision>0</precision>
595
        <conversion_mask/>
596
        <date_format_lenient>false</date_format_lenient>
597
        <encoding/>
598
        <decimal_symbol/>
599
        <grouping_symbol/>
600
        <currency_symbol/>
601
        <storage_type/>
602
      </meta>      <meta>        <name>orderType</name>
603
        <rename>orderType</rename>
604
        <type>-</type>
605
        <length>15</length>
606
        <precision>0</precision>
607
        <conversion_mask/>
608
        <date_format_lenient>false</date_format_lenient>
609
        <encoding/>
610
        <decimal_symbol/>
611
        <grouping_symbol/>
612
        <currency_symbol/>
613
        <storage_type/>
614
      </meta>      <meta>        <name>dateId</name>
615
        <rename>dateId</rename>
616
        <type>-</type>
617
        <length>15</length>
618
        <precision>0</precision>
619
        <conversion_mask/>
620
        <date_format_lenient>false</date_format_lenient>
621
        <encoding/>
622
        <decimal_symbol/>
623
        <grouping_symbol/>
624
        <currency_symbol/>
625
        <storage_type/>
626
      </meta>      <meta>        <name>repeatType</name>
627
        <rename>repeatType</rename>
628
        <type>-</type>
629
        <length>15</length>
630
        <precision>0</precision>
631
        <conversion_mask/>
632
        <date_format_lenient>false</date_format_lenient>
633
        <encoding/>
634
        <decimal_symbol/>
635
        <grouping_symbol/>
636
        <currency_symbol/>
637
        <storage_type/>
638
      </meta>      <meta>        <name>repeatFrequency</name>
639
        <rename>repeatFrequency</rename>
640
        <type>-</type>
641
        <length>15</length>
642
        <precision>0</precision>
643
        <conversion_mask/>
644
        <date_format_lenient>false</date_format_lenient>
645
        <encoding/>
646
        <decimal_symbol/>
647
        <grouping_symbol/>
648
        <currency_symbol/>
649
        <storage_type/>
650
      </meta>      <meta>        <name>transactionId</name>
651
        <rename>transactionId</rename>
652
        <type>-</type>
653
        <length>9</length>
654
        <precision>0</precision>
655
        <conversion_mask/>
656
        <date_format_lenient>false</date_format_lenient>
657
        <encoding/>
658
        <decimal_symbol/>
659
        <grouping_symbol/>
660
        <currency_symbol/>
661
        <storage_type/>
662
      </meta>      <meta>        <name>amount</name>
663
        <rename>amount</rename>
664
        <type>Number</type>
665
        <length>9</length>
666
        <precision>0</precision>
667
        <conversion_mask/>
668
        <date_format_lenient>false</date_format_lenient>
669
        <encoding/>
670
        <decimal_symbol/>
671
        <grouping_symbol/>
672
        <currency_symbol/>
673
        <storage_type/>
674
      </meta>      <meta>        <name>transferPrice</name>
675
        <rename>transferPrice</rename>
676
        <type>Number</type>
677
        <length>9</length>
678
        <precision>0</precision>
679
        <conversion_mask/>
680
        <date_format_lenient>false</date_format_lenient>
681
        <encoding/>
682
        <decimal_symbol/>
683
        <grouping_symbol/>
684
        <currency_symbol/>
685
        <storage_type/>
686
      </meta>      <meta>        <name>pincode</name>
687
        <rename>pincode</rename>
688
        <type>-</type>
689
        <length>10</length>
690
        <precision>-2</precision>
691
        <conversion_mask/>
692
        <date_format_lenient>false</date_format_lenient>
693
        <encoding/>
694
        <decimal_symbol/>
695
        <grouping_symbol/>
696
        <currency_symbol/>
697
        <storage_type/>
698
      </meta>      <meta>        <name>itemId</name>
699
        <rename>itemId</rename>
700
        <type>Integer</type>
701
        <length>9</length>
702
        <precision>0</precision>
703
        <conversion_mask/>
704
        <date_format_lenient>false</date_format_lenient>
705
        <encoding/>
706
        <decimal_symbol/>
707
        <grouping_symbol/>
708
        <currency_symbol/>
709
        <storage_type/>
710
      </meta>      <meta>        <name>quantity</name>
711
        <rename>quantity</rename>
712
        <type>-</type>
713
        <length>-2</length>
714
        <precision>-2</precision>
715
        <conversion_mask/>
716
        <date_format_lenient>false</date_format_lenient>
717
        <encoding/>
718
        <decimal_symbol/>
719
        <grouping_symbol/>
720
        <currency_symbol/>
721
        <storage_type/>
722
      </meta>      <meta>        <name>status</name>
723
        <rename>status</rename>
724
        <type>-</type>
725
        <length>9</length>
726
        <precision>0</precision>
727
        <conversion_mask/>
728
        <date_format_lenient>false</date_format_lenient>
729
        <encoding/>
730
        <decimal_symbol/>
731
        <grouping_symbol/>
732
        <currency_symbol/>
733
        <storage_type/>
734
      </meta>      <meta>        <name>firstOrderType</name>
735
        <rename>firstOrderType</rename>
736
        <type>-</type>
737
        <length>15</length>
738
        <precision>0</precision>
739
        <conversion_mask/>
740
        <date_format_lenient>false</date_format_lenient>
741
        <encoding/>
742
        <decimal_symbol/>
743
        <grouping_symbol/>
744
        <currency_symbol/>
745
        <storage_type/>
746
      </meta>      <meta>        <name>firstOrderDate</name>
747
        <rename>firstOrderDate</rename>
748
        <type>-</type>
749
        <length>15</length>
750
        <precision>0</precision>
751
        <conversion_mask/>
752
        <date_format_lenient>false</date_format_lenient>
753
        <encoding/>
754
        <decimal_symbol/>
755
        <grouping_symbol/>
756
        <currency_symbol/>
757
        <storage_type/>
758
      </meta>    </fields>     <cluster_schema/>
759
 <remotesteps>   <input>   </input>   <output>   </output> </remotesteps>    <GUI>
760
      <xloc>274</xloc>
761
      <yloc>145</yloc>
762
      <draw>Y</draw>
763
      </GUI>
764
    </step>
765
 
6541 anupam.sin 766
  <step_error_handling>
767
  </step_error_handling>
768
   <slave-step-copy-partition-distribution>
769
</slave-step-copy-partition-distribution>
770
   <slave_transformation>N</slave_transformation>
771
</transformation>