This closes #296
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7725a47a Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7725a47a Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/7725a47a Branch: refs/heads/master Commit: 7725a47a7918018b834a535baf2c5a5049bb9c6e Parents: 199ec2e 3755c55 Author: Kenneth Knowles <k...@google.com> Authored: Mon May 9 10:11:34 2016 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Mon May 9 10:11:34 2016 -0700 ---------------------------------------------------------------------- .../FlinkGroupAlsoByWindowWrapper.java | 2 +- .../flink/streaming/GroupAlsoByWindowTest.java | 7 +- .../beam/sdk/testing/WindowFnTestUtils.java | 4 +- .../sdk/transforms/windowing/OutputTimeFn.java | 1 - .../beam/sdk/transforms/windowing/Sessions.java | 8 -- .../transforms/windowing/SlidingWindows.java | 23 ++---- .../beam/sdk/transforms/windowing/WindowFn.java | 82 ++++---------------- .../apache/beam/sdk/util/WindowingStrategy.java | 55 ++++++++++++- .../sdk/transforms/join/CoGroupByKeyTest.java | 7 +- .../sdk/transforms/windowing/WindowTest.java | 31 +++++--- .../sdk/transforms/windowing/WindowingTest.java | 9 ++- .../sdk/util/GroupAlsoByWindowsProperties.java | 65 +++------------- ...oupAlsoByWindowsViaOutputBufferDoFnTest.java | 8 +- .../beam/sdk/util/ReduceFnRunnerTest.java | 6 ++ .../apache/beam/sdk/util/ReduceFnTester.java | 9 ++- .../CopyOnAccessInMemoryStateInternalsTest.java | 6 +- 16 files changed, 136 insertions(+), 187 deletions(-) ----------------------------------------------------------------------
