Hi,
yes that is true. The way you would now write such a function is this:
private static class MyIterableFunction implements
AllWindowFunction<Iterable<Tuple2<String, Integer>>, Tuple2<String, Integer>,
TimeWindow> {
private static final long serialVersionUID = 1L;
@Override
public void apply(
TimeWindow window,
Iterable<Tuple2<String, Integer>> values,
Collector<Tuple2<String, Integer>> out) throws Exception {
}
}
(I used Tuple2<String, Integer> as an example input type here.)
and then you can use it with AllWindowedStream.apply(new MyIterableFunction());
> On 25 Feb 2016, at 13:29, HungChang <[email protected]> wrote:
>
> Thank you for your reply.
>
> The following in the current master looks like not iterable? because the
> parameter is IN rather than Iterable<IN>
> So I still have problem to iterate,,,
>
> @Public
> public interface AllWindowFunction<IN, OUT, W extends Window> extends
> Function, Serializable {
>
> /**
> * Evaluates the window and outputs none or several elements.
> *
> * @param window The window that is being evaluated.
> * @param values The elements in the window being evaluated.
> * @param out A collector for emitting elements.
> *
> * @throws Exception The function may throw exceptions to fail the
> program
> and trigger recovery.
> */
> void apply(W window, IN values, Collector<OUT> out) throws Exception;
> }
>
> https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AllWindowFunction.java
>
> Best,
>
> Hung
>
>
>
> --
> View this message in context:
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/The-way-to-itearte-instances-in-AllWindowFunction-in-current-Master-branch-tp5137p5145.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive at
> Nabble.com.
