This closes #3303
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e066a9d6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e066a9d6 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e066a9d6 Branch: refs/heads/gearpump-runner Commit: e066a9d6dfc4d76f2d7d49de9f744b978982bb81 Parents: 86e1fab ccf7344 Author: Thomas Groh <tg...@google.com> Authored: Thu Jun 8 09:13:57 2017 -0700 Committer: Thomas Groh <tg...@google.com> Committed: Thu Jun 8 09:13:57 2017 -0700 ---------------------------------------------------------------------- .../apache/beam/runners/apex/ApexRunner.java | 59 +-- .../translation/ApexPipelineTranslator.java | 16 +- .../construction/RunnerPCollectionView.java | 8 + .../apache/beam/runners/direct/DirectGraph.java | 4 + .../beam/runners/direct/DirectGraphVisitor.java | 22 +- .../runners/direct/ViewEvaluatorFactory.java | 8 +- .../runners/direct/ViewOverrideFactory.java | 29 +- .../beam/runners/direct/DirectGraphs.java | 7 + .../runners/direct/EvaluationContextTest.java | 5 +- .../ImmutabilityEnforcementFactoryTest.java | 4 +- .../beam/runners/direct/ParDoEvaluatorTest.java | 1 + .../runners/direct/TransformExecutorTest.java | 1 + .../direct/ViewEvaluatorFactoryTest.java | 5 +- .../runners/direct/ViewOverrideFactoryTest.java | 16 +- .../direct/WatermarkCallbackExecutorTest.java | 1 + .../runners/direct/WatermarkManagerTest.java | 1 + .../runners/flink/CreateStreamingFlinkView.java | 154 ++++++++ .../flink/FlinkStreamingPipelineTranslator.java | 36 +- .../FlinkStreamingTransformTranslators.java | 8 +- .../flink/FlinkStreamingViewOverrides.java | 372 ------------------- .../runners/dataflow/BatchViewOverrides.java | 182 +++------ .../runners/dataflow/CreateDataflowView.java | 8 +- .../dataflow/DataflowPipelineTranslator.java | 11 +- .../beam/runners/dataflow/DataflowRunner.java | 17 +- .../dataflow/StreamingViewOverrides.java | 10 +- .../DataflowPipelineTranslatorTest.java | 6 +- .../spark/translation/TransformTranslator.java | 50 +-- .../beam/sdk/runners/TransformHierarchy.java | 46 ++- .../org/apache/beam/sdk/transforms/Combine.java | 17 +- .../org/apache/beam/sdk/transforms/View.java | 38 +- .../org/apache/beam/sdk/values/PCollection.java | 12 + .../beam/sdk/values/PCollectionViews.java | 14 + .../org/apache/beam/sdk/values/PValueBase.java | 12 - .../sdk/testing/PCollectionViewTesting.java | 8 + 34 files changed, 458 insertions(+), 730 deletions(-) ----------------------------------------------------------------------