This closes #1669: Preliminaries for timers in the direct runner Hold output watermark according to pending timers Allow setting timer by ID in DirectTimerInternals Add UsesTestStream for use with JUnit @Category Add static Window.withOutputTimeFn to match build method Use informative Instant formatter in WatermarkHold Add informative Instant formatter to BoundedWindow
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/57d9bbd7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/57d9bbd7 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/57d9bbd7 Branch: refs/heads/python-sdk Commit: 57d9bbd797edfcf32fdd9284b802fc4f9694e8d2 Parents: ff39516 dfe2e62 Author: Kenneth Knowles <k...@google.com> Authored: Wed Dec 21 13:46:34 2016 -0800 Committer: Kenneth Knowles <k...@google.com> Committed: Wed Dec 21 13:46:34 2016 -0800 ---------------------------------------------------------------------- .../apache/beam/runners/core/WatermarkHold.java | 4 +- .../runners/direct/DirectTimerInternals.java | 2 +- .../beam/runners/direct/WatermarkManager.java | 78 ++++++++++++++++++-- .../apache/beam/sdk/testing/UsesTestStream.java | 24 ++++++ .../sdk/transforms/windowing/BoundedWindow.java | 31 ++++++++ .../beam/sdk/transforms/windowing/Window.java | 9 +++ .../apache/beam/sdk/testing/TestStreamTest.java | 12 +-- 7 files changed, 144 insertions(+), 16 deletions(-) ----------------------------------------------------------------------
