You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2016/06/23 17:01:48 UTC
[5/5] incubator-beam git commit: This closes #308
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 <kl...@google.com>
Authored: Thu Jun 23 10:01:14 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
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(-)
----------------------------------------------------------------------