Aljoscha Krettek created FLINK-2991:
---------------------------------------
Summary: Extend Window Operators to Allow Efficient Fold Operation
Key: FLINK-2991
URL: https://issues.apache.org/jira/browse/FLINK-2991
Project: Flink
Issue Type: Improvement
Components: Streaming
Reporter: Aljoscha Krettek
Right now, a window fold is implemented as a WindowFunction that gets all the
elements as input. No pre-aggregation is performed. The window operator should
be extended to also allow the fold to also be pre-aggregated.
This requires changing the signature of the {{WindowBuffer}} so that it can
emit a type other than the input type.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
