You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fh...@apache.org on 2017/01/19 22:52:35 UTC
[3/3] flink git commit: [hotfix] [docs] Add closing parentheses on
"DataStream API Programming Guide".
[hotfix] [docs] Add closing parentheses on "DataStream API Programming Guide".
This closes #3153.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0c6e0ee9
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0c6e0ee9
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0c6e0ee9
Branch: refs/heads/master
Commit: 0c6e0ee9c15628dcdf76fd7ce4dae4614f589ce4
Parents: 4833e74
Author: Keiji Yoshida <ke...@gmail.com>
Authored: Wed Jan 18 21:01:36 2017 +0900
Committer: Fabian Hueske <fh...@apache.org>
Committed: Thu Jan 19 23:52:00 2017 +0100
----------------------------------------------------------------------
docs/dev/datastream_api.md | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/0c6e0ee9/docs/dev/datastream_api.md
----------------------------------------------------------------------
diff --git a/docs/dev/datastream_api.md b/docs/dev/datastream_api.md
index 850d8c5..4fc79dd 100644
--- a/docs/dev/datastream_api.md
+++ b/docs/dev/datastream_api.md
@@ -348,7 +348,7 @@ windowedStream.reduce (new ReduceFunction<Tuple2<String,Integer>>() {
public Tuple2<String, Integer> reduce(Tuple2<String, Integer> value1, Tuple2<String, Integer> value2) throws Exception {
return new Tuple2<String,Integer>(value1.f0, value1.f1 + value2.f1);
}
-};
+});
{% endhighlight %}
</td>
</tr>
@@ -363,7 +363,7 @@ windowedStream.fold("start", new FoldFunction<Integer, String>() {
public String fold(String current, Integer value) {
return current + "-" + value;
}
-};
+});
{% endhighlight %}
</td>
</tr>