You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/26 14:33:18 UTC
[jira] [Created] (FLINK-3521) Make Iterable part of method
signature for WindowFunction
Aljoscha Krettek created FLINK-3521:
---------------------------------------
Summary: Make Iterable part of method signature for WindowFunction
Key: FLINK-3521
URL: https://issues.apache.org/jira/browse/FLINK-3521
Project: Flink
Issue Type: Improvement
Components: Streaming
Reporter: Aljoscha Krettek
Assignee: Aljoscha Krettek
Priority: Blocker
After discussion with [~StephanEwen],[~rmetzger], [~fhueske] it was decided that the signature of WindowFunction should be changed.
Right now, the signature is {{WindowFunction<IN, OUT, KEY, WINDOW>}}. With the decision of whether the input is an {{Iterable}} nor not residing in the signature of the method on {{WindowedStream}}, for example:
- {{WindowedStream.apply(WindowFunction<Iterable<IN>>, OUT, KEY, WINDOW>}}
- {{WindowedStream.apply(ReduceFunction, WindowFunction<IN, OUT, KEY, WINDOW>}}
The {{Iterable<>}} should be moved into the signature of the {{apply}} method, so that it is:
{{void apply(KEY key, W window, Iterable<IN> input, Collector<OUT> out)}}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)