You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2016/08/25 18:49:03 UTC
[60/89] [abbrv] flink git commit: [FLINK-4453] [docs] Scala code
example in Window documentation shows Java
[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 <wu...@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>