This closes #2501
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fdbadfc9 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/fdbadfc9 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/fdbadfc9 Branch: refs/heads/jstorm-runner Commit: fdbadfc9cceecf645f2325777ab32f1cb3041953 Parents: 3c2b855 f3b4960 Author: Thomas Groh <tg...@google.com> Authored: Fri Apr 14 16:52:03 2017 -0700 Committer: Thomas Groh <tg...@google.com> Committed: Fri Apr 14 16:52:03 2017 -0700 ---------------------------------------------------------------------- .../apache/beam/runners/apex/ApexRunner.java | 32 +++-- .../DeduplicatedFlattenFactory.java | 63 +++++---- .../EmptyFlattenAsCreateFactory.java | 20 ++- .../core/construction/PTransformMatchers.java | 2 - .../construction/PTransformReplacements.java | 69 ++++++++++ .../core/construction/PrimitiveCreate.java | 13 +- .../SingleInputOutputOverrideFactory.java | 9 +- .../UnsupportedOverrideFactory.java | 14 +- .../DeduplicatedFlattenFactoryTest.java | 18 +-- .../EmptyFlattenAsCreateFactoryTest.java | 36 ++++- .../PTransformReplacementsTest.java | 131 +++++++++++++++++++ .../SingleInputOutputOverrideFactoryTest.java | 31 ++--- .../UnsupportedOverrideFactoryTest.java | 11 +- ...ectGBKIntoKeyedWorkItemsOverrideFactory.java | 16 ++- .../direct/DirectGroupByKeyOverrideFactory.java | 14 +- .../direct/ParDoMultiOverrideFactory.java | 22 ++-- .../direct/TestStreamEvaluatorFactory.java | 14 +- .../runners/direct/ViewOverrideFactory.java | 18 +-- .../direct/WriteWithShardingFactory.java | 16 +-- .../DirectGroupByKeyOverrideFactoryTest.java | 12 +- .../direct/ParDoMultiOverrideFactoryTest.java | 45 ------- .../direct/TestStreamEvaluatorFactoryTest.java | 12 -- .../runners/direct/ViewOverrideFactoryTest.java | 42 ++++-- .../direct/WriteWithShardingFactoryTest.java | 23 ++-- .../flink/FlinkStreamingPipelineTranslator.java | 56 ++++---- .../dataflow/BatchStatefulParDoOverrides.java | 42 +++--- .../runners/dataflow/BatchViewOverrides.java | 17 ++- .../beam/runners/dataflow/DataflowRunner.java | 92 ++++++------- .../dataflow/PrimitiveParDoSingleFactory.java | 15 ++- .../dataflow/ReshuffleOverrideFactory.java | 12 +- .../dataflow/StreamingViewOverrides.java | 14 +- .../PrimitiveParDoSingleFactoryTest.java | 59 +++++++-- .../beam/runners/spark/TestSparkRunner.java | 14 +- .../main/java/org/apache/beam/sdk/Pipeline.java | 15 ++- .../sdk/runners/PTransformOverrideFactory.java | 33 +++-- .../beam/sdk/transforms/AppliedPTransform.java | 5 + .../java/org/apache/beam/sdk/PipelineTest.java | 33 ++--- 37 files changed, 675 insertions(+), 415 deletions(-) ----------------------------------------------------------------------
