This closes #2362
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/132d3c5f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/132d3c5f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/132d3c5f Branch: refs/heads/master Commit: 132d3c5f685279ed3e4c0623f6d956650152e86e Parents: 023e6ab 6848950 Author: Eugene Kirpichov <[email protected]> Authored: Fri Mar 31 10:59:53 2017 -0700 Committer: Eugene Kirpichov <[email protected]> Committed: Fri Mar 31 10:59:53 2017 -0700 ---------------------------------------------------------------------- .../translation/WindowAssignTranslator.java | 2 +- .../direct/ParDoMultiOverrideFactory.java | 4 +- .../direct/WindowEvaluatorFactoryTest.java | 7 +- .../beam/runners/dataflow/AssignWindows.java | 4 +- .../dataflow/ReshuffleOverrideFactory.java | 2 +- .../translation/streaming/CreateStreamTest.java | 4 +- .../org/apache/beam/sdk/testing/PAssert.java | 10 +- .../org/apache/beam/sdk/transforms/DoFn.java | 6 +- .../apache/beam/sdk/transforms/GroupByKey.java | 2 +- .../beam/sdk/transforms/WithTimestamps.java | 6 +- .../beam/sdk/transforms/windowing/PaneInfo.java | 2 +- .../beam/sdk/transforms/windowing/Window.java | 508 ++++++++----------- .../org/apache/beam/sdk/util/Reshuffle.java | 2 +- .../java/org/apache/beam/sdk/io/WriteTest.java | 4 +- .../apache/beam/sdk/testing/TestStreamTest.java | 6 +- .../org/apache/beam/sdk/transforms/TopTest.java | 3 +- .../sdk/transforms/windowing/WindowTest.java | 39 +- 17 files changed, 252 insertions(+), 359 deletions(-) ----------------------------------------------------------------------
