Repository: incubator-beam Updated Branches: refs/heads/master c71502dc9 -> 6f52ff940
Closes #489 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6f52ff94 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6f52ff94 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/6f52ff94 Branch: refs/heads/master Commit: 6f52ff940718c93508bf57e3e56f335ec6ae41b9 Parents: c71502d c8d5742 Author: Dan Halperin <[email protected]> Authored: Mon Jun 20 10:49:35 2016 -0700 Committer: Dan Halperin <[email protected]> Committed: Mon Jun 20 10:49:35 2016 -0700 ---------------------------------------------------------------------- README.md | 2 +- runners/flink/README.md | 4 +- .../beam/runners/flink/examples/TFIDF.java | 4 +- .../beam/runners/flink/examples/WordCount.java | 4 +- .../flink/examples/streaming/AutoComplete.java | 4 +- .../flink/examples/streaming/JoinExamples.java | 4 +- .../examples/streaming/KafkaIOExamples.java | 4 +- .../KafkaWindowedWordCountExample.java | 4 +- .../examples/streaming/WindowedWordCount.java | 4 +- runners/flink/runner/pom.xml | 4 +- .../beam/runners/flink/FlinkPipelineRunner.java | 180 ------------------- .../apache/beam/runners/flink/FlinkRunner.java | 179 ++++++++++++++++++ .../runners/flink/FlinkRunnerRegistrar.java | 4 +- .../runners/flink/TestFlinkPipelineRunner.java | 81 --------- .../beam/runners/flink/TestFlinkRunner.java | 81 +++++++++ .../streaming/io/UnboundedFlinkSource.java | 6 +- .../streaming/state/FlinkStateInternals.java | 2 +- .../runners/flink/FlinkRunnerRegistrarTest.java | 8 +- .../beam/runners/flink/FlinkTestPipeline.java | 4 +- 19 files changed, 291 insertions(+), 292 deletions(-) ----------------------------------------------------------------------
