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 <[email protected]> Authored: Fri Dec 2 13:16:22 2016 -0800 Committer: Thomas Groh <[email protected]> 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(-) ----------------------------------------------------------------------
