This closes #528
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/bf67d8ed Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/bf67d8ed Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/bf67d8ed Branch: refs/heads/master Commit: bf67d8edc4096ce0f63b4aa1d6a8121a230ed48d Parents: 41faee4 244e8e8 Author: Kenneth Knowles <[email protected]> Authored: Fri Jun 24 09:27:35 2016 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Fri Jun 24 09:27:35 2016 -0700 ---------------------------------------------------------------------- .../beam/sdk/util/ReduceFnRunnerTest.java | 3 +- .../apache/beam/sdk/util/ReduceFnTester.java | 5 ++- .../flink/streaming/GroupAlsoByWindowTest.java | 2 +- .../transforms/windowing/AfterWatermark.java | 38 ++++---------------- .../beam/sdk/transforms/windowing/Trigger.java | 7 +--- .../transforms/windowing/TriggerBuilder.java | 29 --------------- .../beam/sdk/transforms/windowing/Window.java | 10 +++--- .../windowing/AfterProcessingTimeTest.java | 3 +- .../windowing/AfterWatermarkTest.java | 24 ++++++------- .../org/apache/beam/sdk/util/TriggerTester.java | 11 +++--- 10 files changed, 33 insertions(+), 99 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/bf67d8ed/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Window.java ----------------------------------------------------------------------
