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 <t...@apache.org> Authored: Wed Nov 2 21:16:24 2016 -0700 Committer: Thomas Weise <t...@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(-) ----------------------------------------------------------------------
