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/master Commit: c08ebbe79dc86230f6a3f0b983f861ebe039917c Parents: 9197d1e 5553c60 Author: Thomas Weise <[email protected]> Authored: Mon Nov 7 19:00:31 2016 -0800 Committer: Thomas Weise <[email protected]> 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(-) ----------------------------------------------------------------------
