You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jb...@apache.org on 2016/09/07 04:11:26 UTC
[2/2] incubator-beam git commit: [BEAM-242] This closes #919
[BEAM-242] This closes #919
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/26635d7f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/26635d7f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/26635d7f
Branch: refs/heads/master
Commit: 26635d7fb3d92185845d269909a3d399099df7da
Parents: 3878546 dafb805
Author: Jean-Baptiste Onofr� <jb...@apache.org>
Authored: Wed Sep 7 06:11:02 2016 +0200
Committer: Jean-Baptiste Onofr� <jb...@apache.org>
Committed: Wed Sep 7 06:11:02 2016 +0200
----------------------------------------------------------------------
runners/flink/examples/pom.xml | 2 --
.../beam/runners/flink/examples/WordCount.java | 9 ++++++
.../runners/flink/examples/package-info.java | 22 +++++++++++++
.../flink/examples/streaming/AutoComplete.java | 5 +--
.../flink/examples/streaming/JoinExamples.java | 3 +-
.../examples/streaming/KafkaIOExamples.java | 34 ++++++++++----------
.../KafkaWindowedWordCountExample.java | 27 +++++++++++++---
.../examples/streaming/WindowedWordCount.java | 19 +++++++----
.../flink/examples/streaming/package-info.java | 22 +++++++++++++
9 files changed, 110 insertions(+), 33 deletions(-)
----------------------------------------------------------------------