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/12/06 16:41:11 UTC

[21/50] [abbrv] incubator-beam git commit: This closes #1260

This closes #1260


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a0884492
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a0884492
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/a0884492

Branch: refs/heads/gearpump-runner
Commit: a0884492a5c037a7fe58a1f011db560f9c228ae0
Parents: 0fb5610 d989123
Author: Thomas Groh <tg...@google.com>
Authored: Fri Dec 2 13:16:22 2016 -0800
Committer: Thomas Groh <tg...@google.com>
Committed: Fri Dec 2 13:16:22 2016 -0800

----------------------------------------------------------------------
 .../beam/runners/core/ReduceFnRunnerTest.java   |   5 +-
 .../beam/runners/core/SplittableParDoTest.java  |  38 ++--
 .../beam/runners/core/WindowMatchers.java       | 204 +++++++++++++++++++
 .../beam/runners/core/WindowMatchersTest.java   |  82 ++++++++
 .../direct/WindowEvaluatorFactoryTest.java      |   4 +-
 .../apache/beam/sdk/testing/GatherAllPanes.java |  88 ++++++++
 .../org/apache/beam/sdk/testing/PAssert.java    |  77 +++----
 .../apache/beam/sdk/testing/PaneExtractors.java |  55 +++--
 .../beam/sdk/testing/ValueInSingleWindow.java   | 134 ++++++++++++
 .../apache/beam/sdk/transforms/DoFnTester.java  |  58 +++---
 .../apache/beam/sdk/util/GatherAllPanes.java    |  86 --------
 .../apache/beam/sdk/util/IdentityWindowFn.java  |   2 +-
 .../org/apache/beam/sdk/WindowMatchers.java     | 204 -------------------
 .../org/apache/beam/sdk/WindowMatchersTest.java |  82 --------
 .../beam/sdk/testing/GatherAllPanesTest.java    | 140 +++++++++++++
 .../beam/sdk/testing/PaneExtractorsTest.java    | 133 ++++++------
 .../testing/ValueInSingleWindowCoderTest.java   |  51 +++++
 .../beam/sdk/util/GatherAllPanesTest.java       | 143 -------------
 18 files changed, 893 insertions(+), 693 deletions(-)
----------------------------------------------------------------------