Repository: beam Updated Branches: refs/heads/master c687887d2 -> 99e60f4c0
This closes #3238 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/99e60f4c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/99e60f4c Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/99e60f4c Branch: refs/heads/master Commit: 99e60f4c0e28b28fbf3f115bedd363c93a40e930 Parents: c687887 6ad6433 Author: Thomas Groh <[email protected]> Authored: Fri May 26 13:18:55 2017 -0700 Committer: Thomas Groh <[email protected]> Committed: Fri May 26 13:18:55 2017 -0700 ---------------------------------------------------------------------- .../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 ---------- 19 files changed, 35 insertions(+), 434 deletions(-) ----------------------------------------------------------------------
