Closes #1269
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/15287b83 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/15287b83 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/15287b83 Branch: refs/heads/apex-runner Commit: 15287b83860d49e595d59d3e178cc3fecef4c310 Parents: 51af7e5 a21550f Author: Thomas Weise <t...@apache.org> Authored: Mon Nov 7 10:59:22 2016 -0800 Committer: Thomas Weise <t...@apache.org> Committed: Mon Nov 7 10:59:22 2016 -0800 ---------------------------------------------------------------------- runners/apex/README.md | 76 ++++++++ runners/apex/pom.xml | 1 + .../apache/beam/runners/apex/ApexRunner.java | 82 ++++++++ .../functions/ApexGroupByKeyOperator.java | 2 +- .../io/ApexReadUnboundedInputOperator.java | 2 +- .../apex/translators/utils/ApexStreamTuple.java | 21 ++- .../apex/examples/StreamingWordCountTest.java | 121 ------------ .../runners/apex/examples/WordCountTest.java | 188 +++++++++++++++++++ .../translators/ApexGroupByKeyOperatorTest.java | 112 +++++++++++ .../translators/GroupByKeyTranslatorTest.java | 1 + runners/apex/src/test/resources/words.txt | 3 + 11 files changed, 484 insertions(+), 125 deletions(-) ----------------------------------------------------------------------
