This closes #1667: Support user timers for ParDo in the direct runner No longer reject timers for ParDo in direct runner Deliver timers in the direct runner
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0616245e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0616245e Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/0616245e Branch: refs/heads/master Commit: 0616245e654c60ae94cc2c188f857b74a62d9b24 Parents: 467e385 27b016d Author: Kenneth Knowles <[email protected]> Authored: Tue Jan 3 12:55:17 2017 -0800 Committer: Kenneth Knowles <[email protected]> Committed: Tue Jan 3 12:55:17 2017 -0800 ---------------------------------------------------------------------- runners/direct-java/pom.xml | 1 - ...ecycleManagerRemovingTransformEvaluator.java | 19 +++- .../beam/runners/direct/ParDoEvaluator.java | 9 ++ .../runners/direct/ParDoEvaluatorFactory.java | 2 +- .../direct/ParDoMultiOverrideFactory.java | 13 +-- .../direct/StatefulParDoEvaluatorFactory.java | 15 ++- ...leManagerRemovingTransformEvaluatorTest.java | 103 +++++++++---------- .../apache/beam/sdk/transforms/ParDoTest.java | 74 ++++++++++++- 8 files changed, 162 insertions(+), 74 deletions(-) ----------------------------------------------------------------------
