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/04/30 15:44:31 UTC
[2/2] beam git commit: This closes #2782: fix triggering for
processing time timers
This closes #2782: fix triggering for processing time timers
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/202aae9d
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/202aae9d
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/202aae9d
Branch: refs/heads/master
Commit: 202aae9d3a85a4fff41943e4c9a13618bcf8acc4
Parents: fc55d2f eb86038
Author: Kenneth Knowles <kl...@google.com>
Authored: Sun Apr 30 08:43:35 2017 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Sun Apr 30 08:43:35 2017 -0700
----------------------------------------------------------------------
.../operators/ApexGroupByKeyOperator.java | 41 ++-
.../operators/ApexTimerInternals.java | 155 +++++---
.../translation/ApexStateInternalsTest.java | 368 -------------------
.../operators/ApexTimerInternalsTest.java | 78 +++-
.../utils/ApexStateInternalsTest.java | 367 ++++++++++++++++++
5 files changed, 567 insertions(+), 442 deletions(-)
----------------------------------------------------------------------