Top values in desc order based on key column

[priyadarshikunal]

Code: Select all

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

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

Code: Select all

sequential file-> sort (partition)->transformer-> output

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.