Hi all, Say I have a pipleline like this topic.aggregateByKey( ...) => to downstream
Now for every message in topic it will call aggregateByKey and send it to downstream Is there a way to tell the pipeline that if it gets a certain message then only push the current aggregation result to downstream. Or I can do some configuration like until it has aggregated the result of n messages don't push it to downstream. Or any such logic can only be built in the downstream to check and decide if it needs to process the current aggregation or not. Thanks Sachin
