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/master Commit: 4843dc59c6e87ea0be75f7abd1e312bf5bc5a529 Parents: 0d0a5e2 35a0274 Author: Kenneth Knowles <k...@google.com> Authored: Wed Dec 21 10:15:56 2016 -0800 Committer: Kenneth Knowles <k...@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(-) ----------------------------------------------------------------------
