This closes #2863
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f55d0025 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f55d0025 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f55d0025 Branch: refs/heads/DSL_SQL Commit: f55d00253ef63adb96f96b0491b79d1024b905b6 Parents: b263cb7 9edd859 Author: Thomas Groh <tg...@google.com> Authored: Wed May 3 14:12:05 2017 -0700 Committer: Thomas Groh <tg...@google.com> Committed: Wed May 3 14:12:05 2017 -0700 ---------------------------------------------------------------------- .../direct/AbstractModelEnforcement.java | 1 - .../direct/BoundedReadEvaluatorFactory.java | 2 - .../beam/runners/direct/BundleFactory.java | 3 +- .../org/apache/beam/runners/direct/Clock.java | 2 +- .../runners/direct/CloningBundleFactory.java | 2 - .../beam/runners/direct/CommittedBundle.java | 82 +++++++++++++ .../beam/runners/direct/CommittedResult.java | 1 - .../beam/runners/direct/CompletionCallback.java | 1 - .../CopyOnAccessInMemoryStateInternals.java | 2 +- .../apache/beam/runners/direct/DirectGraph.java | 12 +- .../beam/runners/direct/DirectMetrics.java | 1 - .../beam/runners/direct/DirectRunner.java | 122 ++----------------- .../beam/runners/direct/EmptyInputProvider.java | 1 - .../runners/direct/EmptyTransformEvaluator.java | 50 -------- .../beam/runners/direct/EvaluationContext.java | 3 - .../runners/direct/ExecutorServiceFactory.java | 2 +- .../direct/ExecutorServiceParallelExecutor.java | 1 - .../runners/direct/FlattenEvaluatorFactory.java | 2 - .../GroupAlsoByWindowEvaluatorFactory.java | 2 - .../direct/GroupByKeyOnlyEvaluatorFactory.java | 2 - .../ImmutabilityCheckingBundleFactory.java | 2 - .../direct/ImmutabilityEnforcementFactory.java | 1 - .../direct/ImmutableListBundleFactory.java | 2 - .../beam/runners/direct/ModelEnforcement.java | 10 +- .../runners/direct/ModelEnforcementFactory.java | 3 +- .../beam/runners/direct/NanosOffsetClock.java | 2 +- .../runners/direct/PCollectionViewWriter.java | 34 ++++++ .../beam/runners/direct/ParDoEvaluator.java | 1 - .../runners/direct/ParDoEvaluatorFactory.java | 1 - .../direct/PassthroughTransformEvaluator.java | 1 - .../beam/runners/direct/PipelineExecutor.java | 1 - .../beam/runners/direct/RootInputProvider.java | 1 - .../runners/direct/RootProviderRegistry.java | 1 - ...littableProcessElementsEvaluatorFactory.java | 1 - .../direct/StatefulParDoEvaluatorFactory.java | 1 - .../runners/direct/StepTransformResult.java | 3 +- .../direct/TestStreamEvaluatorFactory.java | 2 - .../beam/runners/direct/TransformEvaluator.java | 3 +- .../direct/TransformEvaluatorFactory.java | 6 +- .../direct/TransformEvaluatorRegistry.java | 1 - .../beam/runners/direct/TransformExecutor.java | 1 - .../beam/runners/direct/TransformResult.java | 3 +- .../direct/UnboundedReadEvaluatorFactory.java | 2 - .../beam/runners/direct/UncommittedBundle.java | 57 +++++++++ .../runners/direct/ViewEvaluatorFactory.java | 3 +- .../beam/runners/direct/WatermarkManager.java | 3 +- .../runners/direct/WindowEvaluatorFactory.java | 2 - .../direct/BoundedReadEvaluatorFactoryTest.java | 2 - .../direct/CloningBundleFactoryTest.java | 2 - .../runners/direct/CommittedResultTest.java | 12 +- .../beam/runners/direct/DirectMetricsTest.java | 1 - .../runners/direct/EvaluationContextTest.java | 3 - .../direct/FlattenEvaluatorFactoryTest.java | 2 - .../direct/GroupByKeyEvaluatorFactoryTest.java | 2 - .../GroupByKeyOnlyEvaluatorFactoryTest.java | 2 - .../ImmutabilityCheckingBundleFactoryTest.java | 2 - .../ImmutabilityEnforcementFactoryTest.java | 1 - .../direct/ImmutableListBundleFactoryTest.java | 2 - .../beam/runners/direct/ParDoEvaluatorTest.java | 1 - .../StatefulParDoEvaluatorFactoryTest.java | 2 - .../runners/direct/StepTransformResultTest.java | 1 - .../direct/TestStreamEvaluatorFactoryTest.java | 1 - .../runners/direct/TransformExecutorTest.java | 1 - .../UnboundedReadEvaluatorFactoryTest.java | 2 - .../direct/ViewEvaluatorFactoryTest.java | 2 - .../runners/direct/WatermarkManagerTest.java | 2 - .../direct/WindowEvaluatorFactoryTest.java | 2 - 67 files changed, 214 insertions(+), 273 deletions(-) ----------------------------------------------------------------------
