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/08 03:04:39 UTC
[6/6] incubator-beam git commit: Closes #1213
Closes #1213
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c08ebbe7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c08ebbe7
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/c08ebbe7
Branch: refs/heads/apex-runner
Commit: c08ebbe79dc86230f6a3f0b983f861ebe039917c
Parents: 9197d1e 5553c60
Author: Thomas Weise <th...@apache.org>
Authored: Mon Nov 7 19:00:31 2016 -0800
Committer: Thomas Weise <th...@apache.org>
Committed: Mon Nov 7 19:00:31 2016 -0800
----------------------------------------------------------------------
.../runners/apex/ApexPipelineTranslator.java | 185 -------
.../apache/beam/runners/apex/ApexRunner.java | 13 +-
.../beam/runners/apex/ApexRunnerResult.java | 2 +-
.../translation/ApexPipelineTranslator.java | 179 +++++++
.../translation/CreateValuesTranslator.java | 48 ++
.../FlattenPCollectionTranslator.java | 129 +++++
.../apex/translation/GroupByKeyTranslator.java | 42 ++
.../translation/ParDoBoundMultiTranslator.java | 142 ++++++
.../apex/translation/ParDoBoundTranslator.java | 64 +++
.../translation/ReadUnboundedTranslator.java | 42 ++
.../apex/translation/TransformTranslator.java | 31 ++
.../apex/translation/TranslationContext.java | 178 +++++++
.../operators/ApexFlattenOperator.java | 125 +++++
.../operators/ApexGroupByKeyOperator.java | 478 +++++++++++++++++++
.../operators/ApexParDoOperator.java | 375 +++++++++++++++
.../ApexReadUnboundedInputOperator.java | 155 ++++++
.../translation/operators/package-info.java | 22 +
.../runners/apex/translation/package-info.java | 22 +
.../translation/utils/ApexStateInternals.java | 438 +++++++++++++++++
.../apex/translation/utils/ApexStreamTuple.java | 222 +++++++++
.../utils/CoderAdapterStreamCodec.java | 69 +++
.../apex/translation/utils/NoOpStepContext.java | 72 +++
.../utils/SerializablePipelineOptions.java | 60 +++
.../utils/ValueAndCoderKryoSerializable.java | 77 +++
.../apex/translation/utils/ValuesSource.java | 149 ++++++
.../apex/translation/utils/package-info.java | 22 +
.../translators/CreateValuesTranslator.java | 48 --
.../FlattenPCollectionTranslator.java | 129 -----
.../apex/translators/GroupByKeyTranslator.java | 42 --
.../translators/ParDoBoundMultiTranslator.java | 142 ------
.../apex/translators/ParDoBoundTranslator.java | 64 ---
.../translators/ReadUnboundedTranslator.java | 42 --
.../apex/translators/TransformTranslator.java | 31 --
.../apex/translators/TranslationContext.java | 178 -------
.../functions/ApexFlattenOperator.java | 125 -----
.../functions/ApexGroupByKeyOperator.java | 478 -------------------
.../functions/ApexParDoOperator.java | 375 ---------------
.../translators/functions/package-info.java | 22 -
.../io/ApexReadUnboundedInputOperator.java | 154 ------
.../apex/translators/io/ValuesSource.java | 149 ------
.../apex/translators/io/package-info.java | 22 -
.../runners/apex/translators/package-info.java | 22 -
.../translators/utils/ApexStateInternals.java | 438 -----------------
.../apex/translators/utils/ApexStreamTuple.java | 222 ---------
.../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 -
.../translation/ApexGroupByKeyOperatorTest.java | 112 +++++
.../FlattenPCollectionTranslatorTest.java | 99 ++++
.../translation/GroupByKeyTranslatorTest.java | 246 ++++++++++
.../translation/ParDoBoundTranslatorTest.java | 340 +++++++++++++
.../translation/ReadUnboundTranslatorTest.java | 129 +++++
.../utils/ApexStateInternalsTest.java | 361 ++++++++++++++
.../translation/utils/CollectionSource.java | 136 ++++++
.../translation/utils/PipelineOptionsTest.java | 84 ++++
.../translators/ApexGroupByKeyOperatorTest.java | 112 -----
.../FlattenPCollectionTranslatorTest.java | 99 ----
.../translators/GroupByKeyTranslatorTest.java | 246 ----------
.../translators/ParDoBoundTranslatorTest.java | 340 -------------
.../translators/ReadUnboundTranslatorTest.java | 129 -----
.../utils/ApexStateInternalsTest.java | 361 --------------
.../translators/utils/CollectionSource.java | 136 ------
.../translators/utils/PipelineOptionsTest.java | 84 ----
65 files changed, 4653 insertions(+), 4685 deletions(-)
----------------------------------------------------------------------