This closes #124
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9ff42696 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9ff42696 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/9ff42696 Branch: refs/heads/master Commit: 9ff426964835def796dc0efd47f309ea521beb4f Parents: c8ed398 450dd85 Author: bchambers <bchamb...@google.com> Authored: Fri Apr 15 11:28:15 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Fri Apr 15 11:28:15 2016 -0700 ---------------------------------------------------------------------- .../beam/sdk/transforms/windowing/AfterAll.java | 10 +++ .../windowing/AfterDelayFromFirstElement.java | 11 ++- .../sdk/transforms/windowing/AfterEach.java | 10 +++ .../sdk/transforms/windowing/AfterFirst.java | 10 +++ .../windowing/AfterProcessingTime.java | 11 ++- .../transforms/windowing/AfterWatermark.java | 24 ++++++- .../transforms/windowing/CalendarWindows.java | 35 ++++++++-- .../sdk/transforms/windowing/FixedWindows.java | 8 +++ .../beam/sdk/transforms/windowing/Never.java | 3 +- .../transforms/windowing/OrFinallyTrigger.java | 5 ++ .../sdk/transforms/windowing/Repeatedly.java | 7 +- .../beam/sdk/transforms/windowing/Sessions.java | 6 ++ .../transforms/windowing/SlidingWindows.java | 9 +++ .../beam/sdk/transforms/windowing/Window.java | 25 +++++++ .../beam/sdk/transforms/windowing/WindowFn.java | 14 +++- .../apache/beam/sdk/util/ReshuffleTrigger.java | 5 ++ .../sdk/transforms/windowing/AfterAllTest.java | 5 ++ .../sdk/transforms/windowing/AfterEachTest.java | 10 +++ .../transforms/windowing/AfterFirstTest.java | 6 ++ .../sdk/transforms/windowing/AfterPaneTest.java | 6 ++ .../windowing/AfterProcessingTimeTest.java | 31 +++++++++ .../windowing/AfterWatermarkTest.java | 27 ++++++++ .../windowing/CalendarWindowsTest.java | 31 +++++++++ .../transforms/windowing/FixedWindowsTest.java | 14 ++++ .../windowing/OrFinallyTriggerTest.java | 6 ++ .../transforms/windowing/RepeatedlyTest.java | 13 ++++ .../sdk/transforms/windowing/SessionsTest.java | 10 +++ .../windowing/SlidingWindowsTest.java | 20 ++++++ .../sdk/transforms/windowing/StubTrigger.java | 71 ++++++++++++++++++++ .../sdk/transforms/windowing/TriggerTest.java | 2 +- .../sdk/transforms/windowing/WindowTest.java | 59 ++++++++++++++++ .../beam/sdk/util/ReshuffleTriggerTest.java | 10 ++- 32 files changed, 501 insertions(+), 13 deletions(-) ----------------------------------------------------------------------
