You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by th...@apache.org on 2016/11/07 19:02:41 UTC
[2/2] incubator-beam git commit: Closes #1269
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 <th...@apache.org>
Authored: Mon Nov 7 10:59:22 2016 -0800
Committer: Thomas Weise <th...@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(-)
----------------------------------------------------------------------