The question is related to partitioning From a copy stage, cpy_split , i am splitting the record into two links. one goes to the Aggregator, Agg_sum , and one pass to a Join stage, Jn_k1 .The link which is passed to the Aggregator,Agg_sum is Hashed and sorted on a Key,say,K1. In Agg_sum we are calcu...