beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [beam] 01/01: Merge pull request #4343: [BEAM-2795] Use portable constructs in Flink batch translator
Date Sat, 13 Jan 2018 01:31:32 GMT
This is an automated email from the ASF dual-hosted git repository.

kenn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit b88d15009e8da25c71a08affcbcf74fec7622c91
Merge: 8e14be0 5ddf50b
Author: Kenn Knowles <kenn@kennknowles.com>
AuthorDate: Fri Jan 12 17:31:28 2018 -0800

    Merge pull request #4343: [BEAM-2795] Use portable constructs in Flink batch translator

 .../core/construction/CombineTranslation.java      |  69 ++++++++--
 .../construction/PCollectionViewTranslation.java   | 102 +++++++++++++++
 .../core/construction/ParDoTranslation.java        |  67 +---------
 .../core/construction/PipelineTranslation.java     |   2 +-
 .../core/construction/WriteFilesTranslation.java   |   2 +-
 .../core/construction/ParDoTranslationTest.java    |   2 +-
 runners/flink/pom.xml                              |  11 ++
 .../flink/FlinkBatchPipelineTranslator.java        |   5 +-
 .../flink/FlinkBatchTransformTranslators.java      | 143 +++++++++++++++------
 .../flink/FlinkPipelineExecutionEnvironment.java   |   1 +
 10 files changed, 288 insertions(+), 116 deletions(-)

-- 
To stop receiving notification emails like this one, please contact
"commits@beam.apache.org" <commits@beam.apache.org>.

Mime
View raw message