[FLINK-3521] Make Iterable part of method signature for WindowFunction

• Type: Improvement
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 1.0.0
• Component/s: API / DataStream
• Assignee: Aljoscha Krettek
• Reporter: Aljoscha Krettek
• Created: 26/Feb/16 13:32
• Updated: 28/Feb/19 11:15
• Resolved: 26/Feb/16 23:12

Description

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)