You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by da...@apache.org on 2017/05/04 07:17:26 UTC
[20/50] [abbrv] beam git commit: This closes #2863
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(-)
----------------------------------------------------------------------