This closes #3211
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6bb204f3 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6bb204f3 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/6bb204f3 Branch: refs/heads/master Commit: 6bb204f34629d7ece10a28a509fa9194df73d21f Parents: 7568f02 2e2ae9c Author: Thomas Groh <[email protected]> Authored: Fri May 26 09:23:31 2017 -0700 Committer: Thomas Groh <[email protected]> Committed: Fri May 26 09:23:31 2017 -0700 ---------------------------------------------------------------------- .../apache/beam/runners/apex/ApexRunner.java | 119 +++---------- .../apex/translation/TranslationContext.java | 4 +- .../core/construction/TransformInputs.java | 50 ++++++ .../core/construction/TransformInputsTest.java | 166 +++++++++++++++++++ .../beam/runners/direct/DirectGraphVisitor.java | 15 +- .../runners/direct/ParDoEvaluatorFactory.java | 9 +- ...littableProcessElementsEvaluatorFactory.java | 2 + .../direct/StatefulParDoEvaluatorFactory.java | 1 + .../beam/runners/direct/WatermarkManager.java | 17 +- .../beam/runners/direct/ParDoEvaluatorTest.java | 6 +- .../flink/FlinkBatchTranslationContext.java | 3 +- .../flink/FlinkStreamingTranslationContext.java | 3 +- .../dataflow/DataflowPipelineTranslator.java | 5 +- .../apache/beam/runners/spark/SparkRunner.java | 13 ++ .../spark/translation/BoundedDataset.java | 6 + .../spark/translation/EvaluationContext.java | 4 +- .../spark/translation/TransformTranslator.java | 1 + .../spark/translation/StorageLevelTest.java | 4 +- .../beam/sdk/runners/TransformHierarchy.java | 74 +++++++-- .../sdk/runners/TransformHierarchyTest.java | 86 ++++++++++ 20 files changed, 455 insertions(+), 133 deletions(-) ----------------------------------------------------------------------
