beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [1/2] incubator-beam git commit: Closes #489
Date Mon, 20 Jun 2016 17:49:45 GMT
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 <dhalperi@google.com>
Authored: Mon Jun 20 10:49:35 2016 -0700
Committer: Dan Halperin <dhalperi@google.com>
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(-)
----------------------------------------------------------------------



Mime
View raw message