This closes #3352: Fix getAdditionalInputs, etc, for DirectRunner stateful ParDo override
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c528fb2f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c528fb2f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/c528fb2f Branch: refs/heads/master Commit: c528fb2f7c391a98c3f4b9f7c530f65590d20f81 Parents: 346a77f 81a7219 Author: Kenneth Knowles <[email protected]> Authored: Thu Jun 15 16:48:18 2017 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Thu Jun 15 16:48:18 2017 -0700 ---------------------------------------------------------------------- .../direct/ParDoMultiOverrideFactory.java | 90 +++++++++++++++----- .../direct/StatefulParDoEvaluatorFactory.java | 11 ++- .../StatefulParDoEvaluatorFactoryTest.java | 65 +++++++------- 3 files changed, 102 insertions(+), 64 deletions(-) ----------------------------------------------------------------------
