You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2018/07/02 19:52:55 UTC
[beam] 01/01: [BEAM-3971,
BEAM-4284] Remove fromProto for Pipeline and PTransform translation.
This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 4ca20472636c5ba3047bb733a725687a82464c08
Merge: 5cc8a98 f2b4596
Author: Lukasz Cwik <lc...@google.com>
AuthorDate: Mon Jul 2 12:52:50 2018 -0700
[BEAM-3971, BEAM-4284] Remove fromProto for Pipeline and PTransform translation.
.../core/construction/CombineTranslation.java | 214 +++------------------
.../CreatePCollectionViewTranslation.java | 7 +-
.../core/construction/FlattenTranslator.java | 8 +-
.../core/construction/GroupByKeyTranslation.java | 8 +-
.../core/construction/ImpulseTranslation.java | 8 +-
.../core/construction/PTransformTranslation.java | 138 -------------
.../core/construction/ParDoTranslation.java | 113 -----------
.../core/construction/PipelineTranslation.java | 116 -----------
.../runners/core/construction/ReadTranslation.java | 11 +-
.../runners/core/construction/SplittableParDo.java | 9 +-
.../core/construction/TestStreamTranslation.java | 129 ++-----------
.../TransformPayloadTranslatorRegistrar.java | 2 -
.../core/construction/WindowIntoTranslation.java | 11 +-
.../core/construction/WriteFilesTranslation.java | 12 --
.../core/construction/CombineTranslationTest.java | 32 ++-
.../core/construction/PipelineTranslationTest.java | 42 +++-
runners/direct-java/build.gradle | 4 +-
.../apache/beam/runners/direct/DirectOptions.java | 9 -
.../apache/beam/runners/direct/DirectRunner.java | 14 +-
.../beam/runners/direct/MultiStepCombine.java | 61 ++----
.../runners/direct/TransformEvaluatorRegistry.java | 6 -
.../flink/FlinkBatchTransformTranslators.java | 32 +--
.../flink/FlinkPipelineExecutionEnvironment.java | 9 -
.../flink/FlinkStreamingTransformTranslators.java | 134 +++++++++----
.../dataflow/PrimitiveParDoSingleFactory.java | 17 --
.../samza/translation/GroupByKeyTranslator.java | 14 +-
.../samza/translation/SamzaPipelineTranslator.java | 6 -
27 files changed, 236 insertions(+), 930 deletions(-)