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 bb319dbfaa81c27d7ba6b0a465994aa656143100 Merge: 3a52bb1 11590a1 Author: Eugene Kirpichov <[email protected]> AuthorDate: Sat May 12 00:21:12 2018 -0700 Merge pull request #5277: [BEAM-3515] Portable translation of SplittableProcessKeyed [BEAM-3515] Portable translation of SplittableProcessKeyed .../pipeline/src/main/proto/beam_runner_api.proto | 14 ++- .../core/construction/PTransformTranslation.java | 3 + .../core/construction/ParDoTranslation.java | 64 +++++++++-- .../runners/core/construction/SplittableParDo.java | 107 ++++++++++++++++-- .../core/construction/EnvironmentsTest.java | 2 + .../core/construction/ParDoTranslationTest.java | 2 +- .../apache/beam/runners/direct/DirectRunner.java | 2 +- .../runners/flink/FlinkTransformOverrides.java | 3 +- .../FlinkExecutableStageFunctionTest.java | 24 ++-- .../dataflow/DataflowPipelineTranslator.java | 36 +++--- .../dataflow/PrimitiveParDoSingleFactory.java | 37 +++--- .../beam/runners/dataflow/TransformTranslator.java | 5 + .../dataflow/DataflowPipelineTranslatorTest.java | 124 +++++++++++++-------- .../fnexecution/data/GrpcDataServiceTest.java | 2 + 14 files changed, 293 insertions(+), 132 deletions(-) -- To stop receiving notification emails like this one, please contact [email protected].
