[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é <jbono...@apache.org> Authored: Wed Sep 7 06:11:02 2016 +0200 Committer: Jean-Baptiste Onofré <jbono...@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(-) ----------------------------------------------------------------------