This closes #3337: Include Additional PTransform Inputs in Transform Nodes Roll-forward Include Additional PTransform inputs in Transform Nodes
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b4c77167 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b4c77167 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b4c77167 Branch: refs/heads/gearpump-runner Commit: b4c77167f20b8346d22ccff440489592e0de4b52 Parents: 33883ed 696f8b2 Author: Kenneth Knowles <k...@google.com> Authored: Fri Jun 9 15:04:02 2017 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Fri Jun 9 15:04:02 2017 -0700 ---------------------------------------------------------------------- .../apex/translation/TranslationContext.java | 4 +- .../core/construction/TransformInputs.java | 50 ++++++ .../core/construction/TransformInputsTest.java | 166 +++++++++++++++++++ .../apache/beam/runners/direct/DirectGraph.java | 34 +++- .../beam/runners/direct/DirectGraphVisitor.java | 26 ++- .../direct/ExecutorServiceParallelExecutor.java | 2 +- .../runners/direct/ParDoEvaluatorFactory.java | 9 +- ...littableProcessElementsEvaluatorFactory.java | 2 + .../direct/StatefulParDoEvaluatorFactory.java | 1 + .../beam/runners/direct/WatermarkManager.java | 14 +- .../runners/direct/DirectGraphVisitorTest.java | 10 +- .../runners/direct/EvaluationContextTest.java | 2 +- .../beam/runners/direct/ParDoEvaluatorTest.java | 6 +- .../flink/FlinkBatchTranslationContext.java | 3 +- .../flink/FlinkStreamingTranslationContext.java | 3 +- .../dataflow/DataflowPipelineTranslator.java | 5 +- .../spark/translation/EvaluationContext.java | 4 +- .../beam/sdk/runners/TransformHierarchy.java | 28 +++- 18 files changed, 323 insertions(+), 46 deletions(-) ----------------------------------------------------------------------
