beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [27/39] incubator-beam git commit: Closes #1269
Date Sat, 12 Nov 2016 02:28:45 GMT
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/master
Commit: 15287b83860d49e595d59d3e178cc3fecef4c310
Parents: 51af7e5 a21550f
Author: Thomas Weise <thw@apache.org>
Authored: Mon Nov 7 10:59:22 2016 -0800
Committer: Thomas Weise <thw@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(-)
----------------------------------------------------------------------



Mime
View raw message