You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2015/03/24 00:18:01 UTC
flink git commit: [docs] Fixes Java broadcast variable example
Repository: flink
Updated Branches:
refs/heads/master e83d1ec10 -> 80dd85900
[docs] Fixes Java broadcast variable example
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/80dd8590
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/80dd8590
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/80dd8590
Branch: refs/heads/master
Commit: 80dd859002c596e0e9462e4bf99a93c84c815a7a
Parents: e83d1ec
Author: Till Rohrmann <tr...@apache.org>
Authored: Tue Mar 24 00:17:34 2015 +0100
Committer: Till Rohrmann <tr...@apache.org>
Committed: Tue Mar 24 00:17:34 2015 +0100
----------------------------------------------------------------------
docs/programming_guide.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/80dd8590/docs/programming_guide.md
----------------------------------------------------------------------
diff --git a/docs/programming_guide.md b/docs/programming_guide.md
index 4e15b91..3fb1702 100644
--- a/docs/programming_guide.md
+++ b/docs/programming_guide.md
@@ -2505,7 +2505,7 @@ DataSet<Integer> toBroadcast = env.fromElements(1, 2, 3);
DataSet<String> data = env.fromElements("a", "b");
-data.map(new MapFunction<String, String>() {
+data.map(new RichMapFunction<String, String>() {
@Override
public void open(Configuration parameters) throws Exception {
// 3. Access the broadcasted DataSet as a Collection