Repository: beam Updated Branches: refs/heads/master b633abe2c -> 465f4385b
This closes #3188 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/465f4385 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/465f4385 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/465f4385 Branch: refs/heads/master Commit: 465f4385b9e0004c468507b1f403c5a2af4bdbb0 Parents: b633abe 9336230 Author: Thomas Groh <[email protected]> Authored: Mon May 22 18:12:11 2017 -0700 Committer: Thomas Groh <[email protected]> Committed: Mon May 22 18:12:11 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, 280 insertions(+), 28 deletions(-) ----------------------------------------------------------------------
