This closes #474
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/518b23c2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/518b23c2 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/518b23c2 Branch: refs/heads/master Commit: 518b23c2d6dd6fa0e2aaa771b6f2b3de97d83ad1 Parents: 414bb4b 4649eeb Author: Kenneth Knowles <[email protected]> Authored: Wed Jun 15 19:29:17 2016 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Wed Jun 15 19:29:17 2016 -0700 ---------------------------------------------------------------------- runners/direct-java/pom.xml | 2 +- .../direct/AbstractModelEnforcement.java | 4 +- .../direct/BoundedReadEvaluatorFactory.java | 16 +- .../beam/runners/direct/BundleFactory.java | 8 +- .../beam/runners/direct/CommittedResult.java | 6 +- .../beam/runners/direct/CompletionCallback.java | 4 +- .../runners/direct/DirectExecutionContext.java | 106 ++ .../beam/runners/direct/DirectGroupByKey.java | 132 ++ .../direct/DirectGroupByKeyOverrideFactory.java | 41 + .../beam/runners/direct/DirectOptions.java | 101 ++ .../beam/runners/direct/DirectRegistrar.java | 57 + .../beam/runners/direct/DirectRunner.java | 372 +++++ .../runners/direct/DirectTimerInternals.java | 84 ++ .../runners/direct/EmptyTransformEvaluator.java | 4 +- .../direct/EncodabilityEnforcementFactory.java | 2 +- .../beam/runners/direct/EvaluationContext.java | 429 ++++++ .../beam/runners/direct/EvaluatorKey.java | 4 +- .../direct/ExecutorServiceParallelExecutor.java | 30 +- .../runners/direct/FlattenEvaluatorFactory.java | 18 +- .../GroupAlsoByWindowEvaluatorFactory.java | 127 ++ .../direct/GroupByKeyOnlyEvaluatorFactory.java | 186 +++ .../ImmutabilityCheckingBundleFactory.java | 4 +- .../direct/ImmutabilityEnforcementFactory.java | 4 +- .../direct/ImmutableListBundleFactory.java | 163 ++ .../direct/InMemoryWatermarkManager.java | 1420 ----------------- .../runners/direct/InProcessBundleFactory.java | 161 -- .../direct/InProcessBundleOutputManager.java | 51 - .../direct/InProcessEvaluationContext.java | 429 ------ .../direct/InProcessExecutionContext.java | 105 -- .../beam/runners/direct/InProcessExecutor.java | 48 - ...rocessGroupAlsoByWindowEvaluatorFactory.java | 127 -- .../runners/direct/InProcessGroupByKey.java | 132 -- ...InProcessGroupByKeyOnlyEvaluatorFactory.java | 185 --- .../InProcessGroupByKeyOverrideFactory.java | 41 - .../direct/InProcessPipelineOptions.java | 101 -- .../runners/direct/InProcessPipelineRunner.java | 370 ----- .../beam/runners/direct/InProcessRegistrar.java | 55 - .../direct/InProcessSideInputContainer.java | 277 ---- .../runners/direct/InProcessTimerInternals.java | 84 -- .../direct/InProcessTransformResult.java | 84 -- .../beam/runners/direct/ModelEnforcement.java | 8 +- .../runners/direct/ModelEnforcementFactory.java | 2 +- .../beam/runners/direct/ParDoEvaluator.java | 186 +++ .../runners/direct/ParDoInProcessEvaluator.java | 186 --- .../direct/ParDoMultiEvaluatorFactory.java | 10 +- .../direct/ParDoSingleEvaluatorFactory.java | 10 +- .../direct/PassthroughTransformEvaluator.java | 4 +- .../beam/runners/direct/PipelineExecutor.java | 48 + .../beam/runners/direct/SideInputContainer.java | 277 ++++ .../runners/direct/StepTransformResult.java | 8 +- ...readLocalInvalidatingTransformEvaluator.java | 2 +- .../beam/runners/direct/TransformEvaluator.java | 6 +- .../direct/TransformEvaluatorFactory.java | 4 +- .../direct/TransformEvaluatorRegistry.java | 12 +- .../beam/runners/direct/TransformExecutor.java | 16 +- .../beam/runners/direct/TransformResult.java | 84 ++ .../direct/UnboundedReadEvaluatorFactory.java | 16 +- .../direct/UncommittedBundleOutputManager.java | 51 + .../runners/direct/ViewEvaluatorFactory.java | 22 +- .../beam/runners/direct/WatermarkManager.java | 1420 +++++++++++++++++ .../runners/direct/WindowEvaluatorFactory.java | 18 +- .../direct/AvroIOShardedWriteFactoryTest.java | 2 +- .../direct/BoundedReadEvaluatorFactoryTest.java | 14 +- .../runners/direct/CommittedResultTest.java | 14 +- .../runners/direct/DirectRegistrarTest.java | 74 + .../beam/runners/direct/DirectRunnerTest.java | 339 +++++ .../direct/DirectTimerInternalsTest.java | 134 ++ .../EncodabilityEnforcementFactoryTest.java | 4 +- .../runners/direct/EvaluationContextTest.java | 545 +++++++ .../direct/FlattenEvaluatorFactoryTest.java | 16 +- .../direct/GroupByKeyEvaluatorFactoryTest.java | 13 +- .../GroupByKeyOnlyEvaluatorFactoryTest.java | 197 +++ .../ImmutabilityCheckingBundleFactoryTest.java | 6 +- .../ImmutabilityEnforcementFactoryTest.java | 4 +- .../direct/ImmutableListBundleFactoryTest.java | 231 +++ .../direct/InMemoryWatermarkManagerTest.java | 1428 ------------------ .../direct/InProcessBundleFactoryTest.java | 231 --- .../direct/InProcessEvaluationContextTest.java | 545 ------- ...ocessGroupByKeyOnlyEvaluatorFactoryTest.java | 196 --- .../direct/InProcessPipelineRegistrarTest.java | 74 - .../direct/InProcessPipelineRunnerTest.java | 339 ----- .../direct/InProcessSideInputContainerTest.java | 520 ------- .../direct/InProcessTimerInternalsTest.java | 134 -- .../beam/runners/direct/ParDoEvaluatorTest.java | 214 +++ .../direct/ParDoInProcessEvaluatorTest.java | 214 --- .../direct/ParDoMultiEvaluatorFactoryTest.java | 36 +- .../direct/ParDoSingleEvaluatorFactoryTest.java | 36 +- .../runners/direct/SideInputContainerTest.java | 520 +++++++ .../direct/TextIOShardedWriteFactoryTest.java | 2 +- ...LocalInvalidatingTransformEvaluatorTest.java | 4 +- .../runners/direct/TransformExecutorTest.java | 44 +- .../UnboundedReadEvaluatorFactoryTest.java | 18 +- .../direct/ViewEvaluatorFactoryTest.java | 8 +- .../runners/direct/WatermarkManagerTest.java | 1428 ++++++++++++++++++ .../direct/WindowEvaluatorFactoryTest.java | 20 +- .../translation/TransformTranslatorTest.java | 4 +- .../beam/sdk/options/PipelineOptions.java | 2 +- testing/travis/test_wordcount.sh | 4 +- 98 files changed, 7794 insertions(+), 7784 deletions(-) ----------------------------------------------------------------------
