Repository: beam Updated Branches: refs/heads/master def96a2bb -> 890bc1a23
This closes #2284 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/890bc1a2 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/890bc1a2 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/890bc1a2 Branch: refs/heads/master Commit: 890bc1a23f493b042f8c2de5c042970ce5ddca96 Parents: def96a2 036b3da Author: Thomas Groh <[email protected]> Authored: Thu Mar 23 14:21:58 2017 -0700 Committer: Thomas Groh <[email protected]> Committed: Thu Mar 23 14:21:58 2017 -0700 ---------------------------------------------------------------------- .../direct/WindowEvaluatorFactoryTest.java | 5 +- .../apache/beam/sdk/testing/StaticWindows.java | 23 +++++++-- .../sdk/transforms/windowing/GlobalWindows.java | 17 ++++++- .../transforms/windowing/InvalidWindows.java | 2 +- .../windowing/PartitioningWindowFn.java | 23 ++++++--- .../beam/sdk/transforms/windowing/Sessions.java | 2 +- .../transforms/windowing/SlidingWindows.java | 32 +++++++++---- .../beam/sdk/transforms/windowing/WindowFn.java | 18 +++++-- .../transforms/windowing/WindowMappingFn.java | 49 ++++++++++++++++++++ .../apache/beam/sdk/util/IdentityWindowFn.java | 3 +- .../windowing/CalendarWindowsTest.java | 33 +++++++++++++ .../transforms/windowing/FixedWindowsTest.java | 33 +++++++++++++ .../windowing/SlidingWindowsTest.java | 16 +++++-- .../sdk/transforms/windowing/WindowTest.java | 2 +- .../sdk/util/IdentitySideInputWindowFn.java | 16 ++++++- .../sdk/io/gcp/bigquery/BigQueryIOTest.java | 3 +- 16 files changed, 239 insertions(+), 38 deletions(-) ----------------------------------------------------------------------
