beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [11/39] incubator-beam git commit: This closes #540
Date Sat, 12 Nov 2016 02:28:29 GMT
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/master
Commit: c9f1406666f2c86128727534f42b10fb8f93981d
Parents: b8e6eea 9454b3b
Author: Kenneth Knowles <klk@google.com>
Authored: Mon Oct 17 09:47:49 2016 -0700
Committer: Kenneth Knowles <klk@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(+)
----------------------------------------------------------------------



Mime
View raw message