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 <[email protected]> Authored: Wed Feb 22 18:28:33 2017 +0100 Committer: Aljoscha Krettek <[email protected]> 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(-) ----------------------------------------------------------------------
