You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/06/12 16:55:29 UTC
[14/50] [abbrv] beam git commit: This closes #3303
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(-)
----------------------------------------------------------------------