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(-) ----------------------------------------------------------------------
