You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by lc...@apache.org on 2016/08/19 16:21:08 UTC

[4/4] incubator-beam git commit: Add TestStream to the DirectRunner Package

Add TestStream to the DirectRunner Package

This closes #817


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

Branch: refs/heads/master
Commit: 8d31ca0ca084c37dca5a436fa8b784622b25348d
Parents: bfa3b70 a5ef9a9
Author: Luke Cwik <lc...@google.com>
Authored: Fri Aug 19 09:06:08 2016 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Fri Aug 19 09:06:08 2016 -0700

----------------------------------------------------------------------
 .../beam/runners/direct/DirectOptions.java      |  45 +--
 .../beam/runners/direct/DirectRunner.java       |  47 ++-
 .../beam/runners/direct/EvaluationContext.java  |  10 +-
 .../FixedThreadPoolExecutorServiceFactory.java  |  45 ---
 .../beam/runners/direct/NanosOffsetClock.java   |  13 -
 .../direct/TestStreamEvaluatorFactory.java      | 204 ++++++++++
 .../direct/TransformEvaluatorRegistry.java      |  11 +
 .../direct/WriteWithShardingFactory.java        |   2 +-
 .../runners/direct/EvaluationContextTest.java   |   1 +
 .../org/apache/beam/sdk/testing/PAssert.java    |  18 +
 .../apache/beam/sdk/testing/PaneExtractors.java |  18 +
 .../org/apache/beam/sdk/testing/TestStream.java | 372 +++++++++++++++++++
 .../apache/beam/sdk/testing/TestStreamTest.java | 328 ++++++++++++++++
 13 files changed, 1005 insertions(+), 109 deletions(-)
----------------------------------------------------------------------