You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/22 20:12:00 UTC
[jira] [Created] (FLINK-2261) Remove reduce/aggregation from
DataStream
Gyula Fora created FLINK-2261:
---------------------------------
Summary: Remove reduce/aggregation from DataStream
Key: FLINK-2261
URL: https://issues.apache.org/jira/browse/FLINK-2261
Project: Flink
Issue Type: Improvement
Components: Java API, Scala API, Streaming
Affects Versions: 0.10
Reporter: Gyula Fora
Assignee: Gyula Fora
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 parallelism to 1 which should not be encouraged.
I would like to remove these methods from the DataStream api and only keep it for GroupedDataStreams and WindowedDataStream where the aggregation is either executed per-key or per-window.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)