You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jk...@apache.org on 2018/05/03 21:01:23 UTC
[beam] 01/01: Merge pull request #5226: [BEAM-3972] Translate
portable batch pipelines by proto
This is an automated email from the ASF dual-hosted git repository.
jkff pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 5cb3969b53ce7fecb33b347c7113602957f5ee9f
Merge: ca4e284 4686be1
Author: Eugene Kirpichov <ek...@gmail.com>
AuthorDate: Thu May 3 14:01:15 2018 -0700
Merge pull request #5226: [BEAM-3972] Translate portable batch pipelines by proto
[BEAM-3972] Translate portable batch pipelines by proto
...yntheticNodes.java => SyntheticComponents.java} | 8 +-
.../core/construction/graph/FusedPipeline.java | 3 +-
.../construction/graph/OutputDeduplicator.java | 5 +-
runners/flink/build.gradle | 1 +
runners/flink/pom.xml | 11 +
.../FlinkBatchPortablePipelineTranslator.java | 610 +++++++++++++++++++++
...onment.java => FlinkExecutionEnvironments.java} | 153 ++----
.../flink/FlinkPipelineExecutionEnvironment.java | 145 +----
.../flink/FlinkPortablePipelineTranslator.java | 40 ++
.../functions/FlinkExecutableStageFunction.java | 73 +++
.../FlinkExecutableStagePruningFunction.java | 45 ++
.../control/ProcessBundleDescriptors.java | 43 +-
.../{graph => wire}/LengthPrefixUnknownCoders.java | 2 +-
.../beam/runners/fnexecution/wire/WireCoders.java | 65 +++
.../runners/fnexecution/wire/package-info.java} | 28 +-
.../LengthPrefixUnknownCodersTest.java | 2 +-
16 files changed, 900 insertions(+), 334 deletions(-)
--
To stop receiving notification emails like this one, please contact
jkff@apache.org.