Re: Removing reduce/aggregations from non-grouped data streams

I opened a PR for this. Stephan Ewen ezt írta (időpont: 2015. jún. 22., H, 19:25): > +1 totally agreed > > On Mon, Jun 22, 2015 at 5:32 PM, Gyula Fóra wrote: > > > Hey all, > > Currently we have reduce and aggregation methods for non-grouped > > DataSt

Re: Removing reduce/aggregations from non-grouped data streams

+1 totally agreed On Mon, Jun 22, 2015 at 5:32 PM, Gyula Fóra wrote: > Hey all, > Currently we have reduce and aggregation methods for non-grouped > DataStreams as well, which will produce local aggregates depending on the > parallelism of the operator. > > This behaviour is neither intuitive no

Removing reduce/aggregations from non-grouped data streams

Hey all, Currently we have reduce and aggregation methods for non-grouped DataStreams as well, which will produce local aggregates depending on the parallelism of the operator. This behaviour is neither intuitive nor useful as it only produces sensible results if the user specifically sets the par