beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [35/39] incubator-beam git commit: Closes #1213
Date Sat, 12 Nov 2016 02:28:53 GMT
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 <thw@apache.org>
Authored: Mon Nov 7 19:00:31 2016 -0800
Committer: Thomas Weise <thw@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(-)
----------------------------------------------------------------------



Mime
View raw message