flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From HungChang <unicorn.bana...@gmail.com>
Subject Re: The way to itearte instances in AllWindowFunction in current Master branch
Date Thu, 25 Feb 2016 12:29:08 GMT
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.

Mime
View raw message