Sorted Input @ Aggregator

What is the use of sorted input ?

When we do not specify sorted input at Aggregator, it generates the data and index cash based on the input values. It sorts data which is present at cash internally and use those sorted values for aggregation.

When we specify the sorted input, it assumes that data which is coming is already sorted and it do not require to sort it again. When data is not in sorted order, mapping gets fail.


1. First we selected group by port as ID and selected sorted input option.

The input data is like below

ID    NAME    GES_UPDATE_DATE
1    mandar    1/8/2009 4:25:14 AM
2    sudhir    1/8/2009 4:25:26 AM
3    ashish    1/8/2009 4:25:34 AM
4    null    1/8/2009 4:33:40 AM
5    null    1/8/2009 4:33:52 AM
5    null    1/8/2009 4:34:02 AM
1    null    1/8/2009 4:37:12 AM
6    null    1/8/2009 4:38:10 AM



Here, ges_update_date is in sorted order but not the id column values. So when we select id as a group by port and sorted input option, mapping gets fail giving below error

Severity    Timestamp    Node    Thread    Message Code    Message
ERROR    1/7/2009 4:50:05 AM    node01_mandar    TRANSF_1_2_1    TE_7073    Aggregate Error: Expecting keys to be ascending

Now, if you change the group by port to GES_UPDATE_DATE and use option sorted input, mapping will get complete successfully.