beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [5/5] incubator-beam git commit: This closes #308
Date Thu, 23 Jun 2016 17:01:48 GMT
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 <klk@google.com>
Authored: Thu Jun 23 10:01:14 2016 -0700
Committer: Kenneth Knowles <klk@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(-)
----------------------------------------------------------------------



Mime
View raw message