DSXchange

srinivas.g wrote:

Code: Select all

Sequential file --> copy--> copy--->transformer-->aggregator
                                     |                 |
                                                              
                                   Join        <---  filter
                                      |
                                   output

always try to use code tag it preserves the white spaces.


in sort stage "Sort Column A Ascending and ColumnB Descending and Partition on Column A" in transformer use three stage variable
PrevKey
CurrKey
Count (initialize with 1)

in same order mentioned above

prev key to store prev value current for the incoming record

if PrevKey is equal to current one increase the value by 1 else re- initialize with 1, put a constraint on output link as count<4

Hope now you understand.