beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject [6/6] beam git commit: This closes #2072
Date Wed, 22 Feb 2017 17:29:23 GMT
This closes #2072


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/453e37bc
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/453e37bc
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/453e37bc

Branch: refs/heads/master
Commit: 453e37bc60b39e3bcc9a9eaff36c3bfd5c84060b
Parents: 88e8425 e0e7e52
Author: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Authored: Wed Feb 22 18:28:33 2017 +0100
Committer: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Committed: Wed Feb 22 18:28:33 2017 +0100

----------------------------------------------------------------------
 .../flink/FlinkBatchPipelineTranslator.java     |  139 +++
 .../flink/FlinkBatchTransformTranslators.java   |  774 +++++++++++++
 .../flink/FlinkBatchTranslationContext.java     |  154 +++
 .../FlinkPipelineExecutionEnvironment.java      |    7 +-
 .../runners/flink/FlinkPipelineTranslator.java  |   53 +
 .../apache/beam/runners/flink/FlinkRunner.java  |  359 +-----
 .../flink/FlinkStreamingPipelineTranslator.java |  150 +++
 .../FlinkStreamingTransformTranslators.java     | 1043 ++++++++++++++++++
 .../flink/FlinkStreamingTranslationContext.java |  130 +++
 .../flink/FlinkStreamingViewOverrides.java      |  372 +++++++
 .../flink/PipelineTranslationOptimizer.java     |   72 ++
 .../beam/runners/flink/TranslationMode.java     |   31 +
 .../FlinkBatchPipelineTranslator.java           |  139 ---
 .../FlinkBatchTransformTranslators.java         |  775 -------------
 .../FlinkBatchTranslationContext.java           |  154 ---
 .../translation/FlinkPipelineTranslator.java    |   53 -
 .../FlinkStreamingPipelineTranslator.java       |  150 ---
 .../FlinkStreamingTransformTranslators.java     | 1043 ------------------
 .../FlinkStreamingTranslationContext.java       |  130 ---
 .../PipelineTranslationOptimizer.java           |   73 --
 .../flink/translation/TranslationMode.java      |   31 -
 21 files changed, 2927 insertions(+), 2905 deletions(-)
----------------------------------------------------------------------



Mime
View raw message