This closes #86
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ccbf2b80 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ccbf2b80 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/ccbf2b80 Branch: refs/heads/master Commit: ccbf2b8025473d30121d1a5b17ba7118abefcb50 Parents: ac314ee 334ab99 Author: bchambers <bchamb...@google.com> Authored: Mon Apr 4 15:44:35 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Mon Apr 4 15:44:35 2016 -0700 ---------------------------------------------------------------------- .../sdk/runners/inprocess/BundleFactory.java | 50 +++++ .../ExecutorServiceParallelExecutor.java | 5 +- .../ImmutabilityCheckingBundleFactory.java | 131 +++++++++++ .../inprocess/InProcessBundleFactory.java | 157 +++++++++++++ .../inprocess/InProcessEvaluationContext.java | 18 +- .../inprocess/InProcessPipelineRunner.java | 5 + .../BoundedReadEvaluatorFactoryTest.java | 21 +- .../inprocess/FlattenEvaluatorFactoryTest.java | 11 +- .../GroupByKeyEvaluatorFactoryTest.java | 10 +- .../ImmutabilityCheckingBundleFactoryTest.java | 220 +++++++++++++++++++ .../inprocess/InMemoryWatermarkManagerTest.java | 49 +++-- .../inprocess/InProcessBundleFactoryTest.java | 197 +++++++++++++++++ .../InProcessEvaluationContextTest.java | 11 +- .../ParDoMultiEvaluatorFactoryTest.java | 95 ++++---- .../ParDoSingleEvaluatorFactoryTest.java | 129 ++++++----- .../inprocess/TransformExecutorTest.java | 10 +- .../UnboundedReadEvaluatorFactoryTest.java | 10 +- .../inprocess/ViewEvaluatorFactoryTest.java | 5 +- 18 files changed, 980 insertions(+), 154 deletions(-) ----------------------------------------------------------------------
