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.
