Repository: beam Updated Branches: refs/heads/master 16ad7e946 -> d0601b30c
This closes #3206 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d0601b30 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d0601b30 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d0601b30 Branch: refs/heads/master Commit: d0601b30cc46796b887b4290d06b79dbef32c786 Parents: 16ad7e9 94e619d Author: Thomas Groh <[email protected]> Authored: Tue May 23 09:30:39 2017 -0700 Committer: Thomas Groh <[email protected]> Committed: Tue May 23 09:30:39 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 +- .../spark/translation/EvaluationContext.java | 4 +- .../beam/sdk/runners/TransformHierarchy.java | 28 +--- 13 files changed, 28 insertions(+), 280 deletions(-) ----------------------------------------------------------------------
