[FLINK-4453] [docs] Scala code example in Window documentation shows Java This closes #2411
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/42f65e4b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/42f65e4b Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/42f65e4b Branch: refs/heads/flip-6 Commit: 42f65e4b93ef7f71b6252bc9c664bee727fd4278 Parents: 58850f2 Author: Jark Wu <wuchong...@alibaba-inc.com> Authored: Wed Aug 24 11:04:25 2016 +0800 Committer: Stephan Ewen <se...@apache.org> Committed: Wed Aug 24 19:27:28 2016 +0200 ---------------------------------------------------------------------- docs/dev/windows.md | 21 ++++++++++----------- 1 file changed, 10 insertions(+), 11 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/42f65e4b/docs/dev/windows.md ---------------------------------------------------------------------- diff --git a/docs/dev/windows.md b/docs/dev/windows.md index 084a2ee..63505c3 100644 --- a/docs/dev/windows.md +++ b/docs/dev/windows.md @@ -409,19 +409,18 @@ public interface WindowFunction<IN, OUT, KEY, W extends Window> extends Function <div data-lang="scala" markdown="1"> {% highlight scala %} -public interface WindowFunction<IN, OUT, KEY, W extends Window> extends Function, Serializable { +trait WindowFunction[IN, OUT, KEY, W <: Window] extends Function with Serializable { /** - * Evaluates the window and outputs none or several elements. - * - * @param key The key for which this window is evaluated. - * @param window The window that is being evaluated. - * @param input 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(KEY key, W window, Iterable<IN> input, Collector<OUT> out) throws Exception; + * Evaluates the window and outputs none or several elements. + * + * @param key The key for which this window is evaluated. + * @param window The window that is being evaluated. + * @param input 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. + */ + def apply(key: KEY, window: W, input: Iterable[IN], out: Collector[OUT]) } {% endhighlight %} </div>
