You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2016/10/17 16:51:03 UTC
[11/11] incubator-beam git commit: This closes #540
This closes #540
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c9f14066
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c9f14066
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/c9f14066
Branch: refs/heads/apex-runner
Commit: c9f1406666f2c86128727534f42b10fb8f93981d
Parents: b8e6eea 9454b3b
Author: Kenneth Knowles <kl...@google.com>
Authored: Mon Oct 17 09:47:49 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Mon Oct 17 09:47:49 2016 -0700
----------------------------------------------------------------------
runners/apex/pom.xml | 223 +++++++++
.../beam/runners/apex/ApexPipelineOptions.java | 66 +++
.../runners/apex/ApexPipelineTranslator.java | 185 ++++++++
.../apache/beam/runners/apex/ApexRunner.java | 329 +++++++++++++
.../beam/runners/apex/ApexRunnerResult.java | 87 ++++
.../beam/runners/apex/TestApexRunner.java | 59 +++
.../apache/beam/runners/apex/package-info.java | 22 +
.../translators/CreateValuesTranslator.java | 48 ++
.../FlattenPCollectionTranslator.java | 129 ++++++
.../apex/translators/GroupByKeyTranslator.java | 41 ++
.../translators/ParDoBoundMultiTranslator.java | 130 ++++++
.../apex/translators/ParDoBoundTranslator.java | 62 +++
.../translators/ReadUnboundedTranslator.java | 42 ++
.../apex/translators/TransformTranslator.java | 31 ++
.../apex/translators/TranslationContext.java | 168 +++++++
.../functions/ApexFlattenOperator.java | 124 +++++
.../functions/ApexGroupByKeyOperator.java | 462 +++++++++++++++++++
.../functions/ApexParDoOperator.java | 374 +++++++++++++++
.../translators/functions/package-info.java | 22 +
.../io/ApexReadUnboundedInputOperator.java | 145 ++++++
.../apex/translators/io/ValuesSource.java | 149 ++++++
.../apex/translators/io/package-info.java | 22 +
.../runners/apex/translators/package-info.java | 22 +
.../apex/translators/utils/ApexStreamTuple.java | 205 ++++++++
.../utils/CoderAdapterStreamCodec.java | 69 +++
.../apex/translators/utils/NoOpStepContext.java | 72 +++
.../utils/SerializablePipelineOptions.java | 60 +++
.../utils/ValueAndCoderKryoSerializable.java | 77 ++++
.../apex/translators/utils/package-info.java | 22 +
.../apex/examples/StreamingWordCountTest.java | 121 +++++
.../apex/examples/UnboundedTextSource.java | 142 ++++++
.../runners/apex/examples/package-info.java | 22 +
.../FlattenPCollectionTranslatorTest.java | 99 ++++
.../translators/GroupByKeyTranslatorTest.java | 245 ++++++++++
.../translators/ParDoBoundTranslatorTest.java | 206 +++++++++
.../translators/ReadUnboundTranslatorTest.java | 129 ++++++
.../translators/utils/CollectionSource.java | 136 ++++++
.../translators/utils/PipelineOptionsTest.java | 84 ++++
.../apex/src/test/resources/log4j.properties | 35 ++
runners/pom.xml | 1 +
40 files changed, 4667 insertions(+)
----------------------------------------------------------------------