You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/01/03 20:55:44 UTC
[3/3] beam git commit: This closes #1667: Support user timers for
ParDo in the direct runner
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 <kl...@google.com>
Authored: Tue Jan 3 12:55:17 2017 -0800
Committer: Kenneth Knowles <kl...@google.com>
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(-)
----------------------------------------------------------------------