beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From t..@apache.org
Subject [2/2] incubator-beam git commit: Closes #1227
Date Thu, 03 Nov 2016 04:26:47 GMT
Closes #1227


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/51af7e59
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/51af7e59
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/51af7e59

Branch: refs/heads/apex-runner
Commit: 51af7e592327ef711673a2b9828536051a6c3898
Parents: 968eb32 77f4ba2
Author: Thomas Weise <thw@apache.org>
Authored: Wed Nov 2 21:16:24 2016 -0700
Committer: Thomas Weise <thw@apache.org>
Committed: Wed Nov 2 21:16:24 2016 -0700

----------------------------------------------------------------------
 examples/java/pom.xml                           | 31 ++++++++++++++++++++
 runners/apex/pom.xml                            |  2 +-
 .../beam/runners/apex/ApexPipelineOptions.java  |  6 ----
 .../runners/apex/ApexPipelineTranslator.java    |  2 +-
 .../apache/beam/runners/apex/ApexRunner.java    | 12 --------
 .../beam/runners/apex/ApexRunnerResult.java     | 27 +++++++++++++++--
 .../beam/runners/apex/TestApexRunner.java       | 20 +++++++++++--
 .../io/ApexReadUnboundedInputOperator.java      | 13 ++++++--
 .../apex/examples/StreamingWordCountTest.java   |  4 +--
 .../translators/ParDoBoundTranslatorTest.java   |  6 ++--
 10 files changed, 91 insertions(+), 32 deletions(-)
----------------------------------------------------------------------



Mime
View raw message