This closes #308
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/82ae661c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/82ae661c Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/82ae661c Branch: refs/heads/master Commit: 82ae661c5b76b0d8e10caa5599d821f2a10a0064 Parents: f2d2ce5 0810441 Author: Kenneth Knowles <[email protected]> Authored: Thu Jun 23 10:01:14 2016 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Thu Jun 23 10:01:14 2016 -0700 ---------------------------------------------------------------------- .../apache/beam/sdk/util/AssignWindowsDoFn.java | 15 +- .../apache/beam/sdk/util/DoFnRunnerBase.java | 2 +- .../beam/sdk/util/ReduceFnRunnerTest.java | 3 +- .../apache/beam/sdk/util/ReduceFnTester.java | 46 ++--- .../runners/direct/WindowEvaluatorFactory.java | 18 +- .../direct/WindowEvaluatorFactoryTest.java | 178 ++++++++++++------- .../FlinkStreamingTransformTranslators.java | 5 +- .../functions/FlinkAssignContext.java | 15 +- .../functions/FlinkNoElementAssignContext.java | 4 +- .../streaming/FlinkAbstractParDoWrapper.java | 4 +- .../flink/streaming/GroupAlsoByWindowTest.java | 2 +- .../beam/sdk/testing/WindowFnTestUtils.java | 5 +- .../sdk/transforms/windowing/GlobalWindows.java | 5 - .../beam/sdk/transforms/windowing/PaneInfo.java | 4 + .../windowing/PartitioningWindowFn.java | 5 - .../beam/sdk/transforms/windowing/WindowFn.java | 11 +- .../apache/beam/sdk/util/GatherAllPanes.java | 3 +- .../apache/beam/sdk/util/IdentityWindowFn.java | 20 +-- .../org/apache/beam/sdk/util/Reshuffle.java | 3 +- .../org/apache/beam/sdk/WindowMatchers.java | 80 ++++++++- .../org/apache/beam/sdk/WindowMatchersTest.java | 84 +++++++++ .../sdk/util/IdentitySideInputWindowFn.java | 3 +- .../sdk/util/MergingActiveWindowSetTest.java | 6 +- .../org/apache/beam/sdk/util/TriggerTester.java | 14 +- 24 files changed, 370 insertions(+), 165 deletions(-) ----------------------------------------------------------------------
