This closes #256
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b9116ac4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b9116ac4 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/b9116ac4 Branch: refs/heads/master Commit: b9116ac426f989af882e6df5dafc5da6c9f203d8 Parents: bba4c64 e13cacb Author: Kenneth Knowles <k...@google.com> Authored: Fri Apr 29 14:49:11 2016 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Fri Apr 29 14:49:11 2016 -0700 ---------------------------------------------------------------------- .travis.yml | 1 + runners/direct-java/pom.xml | 400 ++++++ .../direct/AbstractModelEnforcement.java | 38 + .../direct/AvroIOShardedWriteFactory.java | 76 + .../direct/BoundedReadEvaluatorFactory.java | 155 ++ .../beam/runners/direct/BundleFactory.java | 49 + .../CachedThreadPoolExecutorServiceFactory.java | 44 + .../org/apache/beam/runners/direct/Clock.java | 30 + .../beam/runners/direct/CommittedResult.java | 46 + .../beam/runners/direct/CompletionCallback.java | 36 + .../direct/ConsumerTrackingPipelineVisitor.java | 173 +++ .../runners/direct/EmptyTransformEvaluator.java | 50 + .../direct/EncodabilityEnforcementFactory.java | 70 + .../beam/runners/direct/EvaluatorKey.java | 55 + .../runners/direct/ExecutorServiceFactory.java | 33 + .../direct/ExecutorServiceParallelExecutor.java | 478 +++++++ .../runners/direct/FlattenEvaluatorFactory.java | 85 ++ .../runners/direct/ForwardingPTransform.java | 62 + .../direct/GroupByKeyEvaluatorFactory.java | 274 ++++ .../ImmutabilityCheckingBundleFactory.java | 131 ++ .../direct/ImmutabilityEnforcementFactory.java | 103 ++ .../direct/InMemoryWatermarkManager.java | 1327 ++++++++++++++++++ .../runners/direct/InProcessBundleFactory.java | 162 +++ .../direct/InProcessBundleOutputManager.java | 51 + .../direct/InProcessEvaluationContext.java | 425 ++++++ .../direct/InProcessExecutionContext.java | 105 ++ .../beam/runners/direct/InProcessExecutor.java | 48 + .../direct/InProcessPipelineOptions.java | 101 ++ .../runners/direct/InProcessPipelineRunner.java | 370 +++++ .../beam/runners/direct/InProcessRegistrar.java | 55 + .../direct/InProcessSideInputContainer.java | 271 ++++ .../runners/direct/InProcessTimerInternals.java | 84 ++ .../direct/InProcessTransformResult.java | 77 + .../direct/KeyedPValueTrackingVisitor.java | 96 ++ .../beam/runners/direct/ModelEnforcement.java | 63 + .../runners/direct/ModelEnforcementFactory.java | 30 + .../beam/runners/direct/NanosOffsetClock.java | 59 + .../direct/PTransformOverrideFactory.java | 33 + .../runners/direct/ParDoInProcessEvaluator.java | 173 +++ .../direct/ParDoMultiEvaluatorFactory.java | 64 + .../direct/ParDoSingleEvaluatorFactory.java | 63 + .../direct/PassthroughTransformEvaluator.java | 49 + .../runners/direct/ShardControlledWrite.java | 81 ++ .../apache/beam/runners/direct/StepAndKey.java | 71 + .../runners/direct/StepTransformResult.java | 165 +++ .../direct/TextIOShardedWriteFactory.java | 78 + .../beam/runners/direct/TransformEvaluator.java | 46 + .../direct/TransformEvaluatorFactory.java | 44 + .../direct/TransformEvaluatorRegistry.java | 77 + .../beam/runners/direct/TransformExecutor.java | 176 +++ .../direct/TransformExecutorService.java | 35 + .../direct/TransformExecutorServices.java | 154 ++ .../direct/UnboundedReadEvaluatorFactory.java | 177 +++ .../runners/direct/ViewEvaluatorFactory.java | 145 ++ .../direct/WatermarkCallbackExecutor.java | 146 ++ .../runners/direct/WindowEvaluatorFactory.java | 131 ++ .../direct/AvroIOShardedWriteFactoryTest.java | 112 ++ .../direct/BoundedReadEvaluatorFactoryTest.java | 290 ++++ .../runners/direct/CommittedResultTest.java | 77 + .../ConsumerTrackingPipelineVisitorTest.java | 272 ++++ .../EncodabilityEnforcementFactoryTest.java | 257 ++++ .../direct/FlattenEvaluatorFactoryTest.java | 141 ++ .../direct/ForwardingPTransformTest.java | 112 ++ .../direct/GroupByKeyEvaluatorFactoryTest.java | 183 +++ .../ImmutabilityCheckingBundleFactoryTest.java | 220 +++ .../ImmutabilityEnforcementFactoryTest.java | 128 ++ .../direct/InMemoryWatermarkManagerTest.java | 1168 +++++++++++++++ .../direct/InProcessBundleFactoryTest.java | 223 +++ .../direct/InProcessEvaluationContextTest.java | 526 +++++++ .../direct/InProcessPipelineRegistrarTest.java | 74 + .../direct/InProcessPipelineRunnerTest.java | 78 + .../direct/InProcessSideInputContainerTest.java | 496 +++++++ .../direct/InProcessTimerInternalsTest.java | 133 ++ .../direct/KeyedPValueTrackingVisitorTest.java | 192 +++ .../apache/beam/runners/direct/MockClock.java | 62 + .../direct/ParDoMultiEvaluatorFactoryTest.java | 431 ++++++ .../direct/ParDoSingleEvaluatorFactoryTest.java | 324 +++++ .../direct/TextIOShardedWriteFactoryTest.java | 112 ++ .../direct/TransformExecutorServicesTest.java | 136 ++ .../runners/direct/TransformExecutorTest.java | 538 +++++++ .../UnboundedReadEvaluatorFactoryTest.java | 334 +++++ .../direct/ViewEvaluatorFactoryTest.java | 101 ++ .../direct/WatermarkCallbackExecutorTest.java | 128 ++ .../direct/WindowEvaluatorFactoryTest.java | 222 +++ runners/pom.xml | 1 + .../inprocess/AbstractModelEnforcement.java | 38 - .../inprocess/AvroIOShardedWriteFactory.java | 76 - .../inprocess/BoundedReadEvaluatorFactory.java | 155 -- .../sdk/runners/inprocess/BundleFactory.java | 49 - .../CachedThreadPoolExecutorServiceFactory.java | 44 - .../beam/sdk/runners/inprocess/Clock.java | 30 - .../sdk/runners/inprocess/CommittedResult.java | 46 - .../runners/inprocess/CompletionCallback.java | 36 - .../ConsumerTrackingPipelineVisitor.java | 173 --- .../inprocess/EmptyTransformEvaluator.java | 50 - .../EncodabilityEnforcementFactory.java | 70 - .../sdk/runners/inprocess/EvaluatorKey.java | 55 - .../inprocess/ExecutorServiceFactory.java | 33 - .../ExecutorServiceParallelExecutor.java | 478 ------- .../inprocess/FlattenEvaluatorFactory.java | 85 -- .../runners/inprocess/ForwardingPTransform.java | 62 - .../inprocess/GroupByKeyEvaluatorFactory.java | 274 ---- .../ImmutabilityCheckingBundleFactory.java | 131 -- .../ImmutabilityEnforcementFactory.java | 103 -- .../inprocess/InMemoryWatermarkManager.java | 1327 ------------------ .../inprocess/InProcessBundleFactory.java | 162 --- .../inprocess/InProcessBundleOutputManager.java | 51 - .../inprocess/InProcessEvaluationContext.java | 425 ------ .../inprocess/InProcessExecutionContext.java | 105 -- .../runners/inprocess/InProcessExecutor.java | 48 - .../inprocess/InProcessPipelineOptions.java | 101 -- .../inprocess/InProcessPipelineRunner.java | 370 ----- .../runners/inprocess/InProcessRegistrar.java | 55 - .../inprocess/InProcessSideInputContainer.java | 271 ---- .../inprocess/InProcessTimerInternals.java | 84 -- .../inprocess/InProcessTransformResult.java | 77 - .../inprocess/KeyedPValueTrackingVisitor.java | 96 -- .../sdk/runners/inprocess/ModelEnforcement.java | 63 - .../inprocess/ModelEnforcementFactory.java | 30 - .../sdk/runners/inprocess/NanosOffsetClock.java | 59 - .../inprocess/PTransformOverrideFactory.java | 33 - .../inprocess/ParDoInProcessEvaluator.java | 173 --- .../inprocess/ParDoMultiEvaluatorFactory.java | 63 - .../inprocess/ParDoSingleEvaluatorFactory.java | 63 - .../PassthroughTransformEvaluator.java | 49 - .../runners/inprocess/ShardControlledWrite.java | 81 -- .../beam/sdk/runners/inprocess/StepAndKey.java | 71 - .../runners/inprocess/StepTransformResult.java | 165 --- .../inprocess/TextIOShardedWriteFactory.java | 78 - .../runners/inprocess/TransformEvaluator.java | 46 - .../inprocess/TransformEvaluatorFactory.java | 44 - .../inprocess/TransformEvaluatorRegistry.java | 77 - .../runners/inprocess/TransformExecutor.java | 176 --- .../inprocess/TransformExecutorService.java | 35 - .../inprocess/TransformExecutorServices.java | 154 -- .../UnboundedReadEvaluatorFactory.java | 177 --- .../runners/inprocess/ViewEvaluatorFactory.java | 145 -- .../inprocess/WatermarkCallbackExecutor.java | 146 -- .../inprocess/WindowEvaluatorFactory.java | 131 -- .../AvroIOShardedWriteFactoryTest.java | 112 -- .../BoundedReadEvaluatorFactoryTest.java | 290 ---- .../runners/inprocess/CommittedResultTest.java | 77 - .../ConsumerTrackingPipelineVisitorTest.java | 272 ---- .../EncodabilityEnforcementFactoryTest.java | 257 ---- .../inprocess/FlattenEvaluatorFactoryTest.java | 141 -- .../inprocess/ForwardingPTransformTest.java | 112 -- .../GroupByKeyEvaluatorFactoryTest.java | 183 --- .../ImmutabilityCheckingBundleFactoryTest.java | 220 --- .../ImmutabilityEnforcementFactoryTest.java | 128 -- .../inprocess/InMemoryWatermarkManagerTest.java | 1168 --------------- .../inprocess/InProcessBundleFactoryTest.java | 223 --- .../InProcessEvaluationContextTest.java | 526 ------- .../InProcessPipelineRegistrarTest.java | 74 - .../inprocess/InProcessPipelineRunnerTest.java | 78 - .../InProcessSideInputContainerTest.java | 496 ------- .../inprocess/InProcessTimerInternalsTest.java | 133 -- .../KeyedPValueTrackingVisitorTest.java | 192 --- .../beam/sdk/runners/inprocess/MockClock.java | 62 - .../ParDoMultiEvaluatorFactoryTest.java | 431 ------ .../ParDoSingleEvaluatorFactoryTest.java | 324 ----- .../TextIOShardedWriteFactoryTest.java | 112 -- .../TransformExecutorServicesTest.java | 136 -- .../inprocess/TransformExecutorTest.java | 538 ------- .../UnboundedReadEvaluatorFactoryTest.java | 334 ----- .../inprocess/ViewEvaluatorFactoryTest.java | 101 -- .../WatermarkCallbackExecutorTest.java | 128 -- .../inprocess/WindowEvaluatorFactoryTest.java | 222 --- sdks/java/pom.xml | 1 - 168 files changed, 14692 insertions(+), 14290 deletions(-) ----------------------------------------------------------------------
