flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Martin Neumann <mneum...@sics.se>
Subject streaming GroupBy + Fold
Date Fri, 02 Oct 2015 16:37:00 GMT

In one of my Programs I run a Fold on a GroupedDataStream. The aim is to
aggregate the values in each group.
It seems the aggregator in the Fold function is shared on operator level,
so all groups that end up on the same operator get mashed together.

Is this the wanted behavior? If so, what do I have to do to separate them?

cheers Martin

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message