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 2016/12/21 22:50:10 UTC
[36/51] [abbrv] incubator-beam git commit: This closes #1673: Require
TimeDomain to delete a timer
This closes #1673: Require TimeDomain to delete a timer
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4843dc59
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4843dc59
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/4843dc59
Branch: refs/heads/python-sdk
Commit: 4843dc59c6e87ea0be75f7abd1e312bf5bc5a529
Parents: 0d0a5e2 35a0274
Author: Kenneth Knowles <kl...@google.com>
Authored: Wed Dec 21 10:15:56 2016 -0800
Committer: Kenneth Knowles <kl...@google.com>
Committed: Wed Dec 21 10:15:56 2016 -0800
----------------------------------------------------------------------
.../operators/ApexGroupByKeyOperator.java | 8 ++++++++
.../beam/runners/core/InMemoryTimerInternals.java | 8 ++++++++
.../beam/runners/direct/DirectTimerInternals.java | 8 ++++++++
.../wrappers/streaming/WindowDoFnOperator.java | 9 +++++++++
.../org/apache/beam/sdk/util/TimerInternals.java | 17 +++++++++++++++--
5 files changed, 48 insertions(+), 2 deletions(-)
----------------------------------------------------------------------