You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by re...@apache.org on 2018/07/24 23:45:11 UTC
[beam] 01/01: Merge pull request #5955: [BEAM-4076] Enable schemas
for more runners
This is an automated email from the ASF dual-hosted git repository.
reuvenlax pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit b87aa6037b37aab95702fd1ace40b835f0f66f55
Merge: d2ac08d 0964b1f
Author: reuvenlax <re...@google.com>
AuthorDate: Tue Jul 24 16:45:03 2018 -0700
Merge pull request #5955: [BEAM-4076] Enable schemas for more runners
runners/apex/build.gradle | 1 -
.../runners/apex/translation/ParDoTranslator.java | 21 +++++++++++++++-
.../translation/operators/ApexParDoOperator.java | 21 ++++++++++++----
.../apex/translation/ParDoTranslatorTest.java | 1 +
.../core/construction/ParDoTranslation.java | 10 ++++++++
runners/flink/build.gradle | 1 -
.../flink/FlinkBatchTransformTranslators.java | 17 ++++++++-----
.../flink/FlinkBatchTranslationContext.java | 10 ++++++++
.../FlinkStreamingPortablePipelineTranslator.java | 10 +++++---
.../flink/FlinkStreamingTransformTranslators.java | 29 +++++++++++++++++-----
.../flink/FlinkStreamingTranslationContext.java | 16 +++++++++++-
.../translation/functions/FlinkDoFnFunction.java | 14 ++++++++---
.../functions/FlinkStatefulDoFnFunction.java | 14 ++++++++---
.../wrappers/streaming/DoFnOperator.java | 21 ++++++++++------
.../streaming/ExecutableStageDoFnOperator.java | 6 ++++-
.../wrappers/streaming/SplittableDoFnOperator.java | 6 ++++-
.../wrappers/streaming/WindowDoFnOperator.java | 6 +++--
.../beam/runners/flink/PipelineOptionsTest.java | 4 +++
.../runners/flink/streaming/DoFnOperatorTest.java | 26 +++++++++++++++++++
.../streaming/ExecutableStageDoFnOperatorTest.java | 4 +++
runners/gearpump/build.gradle | 1 +
runners/samza/build.gradle | 1 -
.../apache/beam/runners/samza/runtime/DoFnOp.java | 8 ++++++
.../runtime/DoFnRunnerWithKeyedInternals.java | 9 ++++---
.../translation/ParDoBoundMultiTranslator.java | 10 ++++++++
runners/spark/build.gradle | 2 --
.../spark/translation/EvaluationContext.java | 10 ++++++++
.../spark/translation/MultiDoFnFunction.java | 13 ++++++++--
.../spark/translation/TransformTranslator.java | 5 +++-
.../streaming/StreamingTransformTranslator.java | 4 +++
30 files changed, 247 insertions(+), 54 deletions(-)