beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [3/3] beam git commit: This closes #1667: Support user timers for ParDo in the direct runner
Date Tue, 03 Jan 2017 20:55:44 GMT
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 <klk@google.com>
Authored: Tue Jan 3 12:55:17 2017 -0800
Committer: Kenneth Knowles <klk@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(-)
----------------------------------------------------------------------



Mime
View raw message