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 <[email protected]> Authored: Tue Mar 24 00:17:34 2015 +0100 Committer: Till Rohrmann <[email protected]> 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
