You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jk...@apache.org on 2017/03/31 18:20:45 UTC
[6/6] beam git commit: This closes #2362
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 <ki...@google.com>
Authored: Fri Mar 31 10:59:53 2017 -0700
Committer: Eugene Kirpichov <ki...@google.com>
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(-)
----------------------------------------------------------------------