This closes #2274
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/75b6567f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/75b6567f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/75b6567f Branch: refs/heads/master Commit: 75b6567f6f883af3707b0092dfbe3585b7d8b7bf Parents: d6f6351 fdc2edd Author: Eugene Kirpichov <[email protected]> Authored: Wed Mar 22 18:12:37 2017 -0700 Committer: Eugene Kirpichov <[email protected]> Committed: Wed Mar 22 18:12:37 2017 -0700 ---------------------------------------------------------------------- .../apache/beam/runners/apex/ApexRunner.java | 3 +- .../beam/runners/direct/DirectRunner.java | 61 ++++---- .../flink/FlinkStreamingPipelineTranslator.java | 3 +- .../beam/runners/dataflow/DataflowRunner.java | 3 +- .../beam/runners/spark/TestSparkRunner.java | 6 +- .../main/java/org/apache/beam/sdk/Pipeline.java | 66 ++++++++- .../beam/sdk/runners/PTransformOverride.java | 44 ++++++ .../java/org/apache/beam/sdk/PipelineTest.java | 138 +++++++++++++++++++ 8 files changed, 287 insertions(+), 37 deletions(-) ----------------------------------------------------------------------
