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
Hej,

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

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