beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tg...@apache.org
Subject [1/3] beam git commit: This closes #2863
Date Wed, 03 May 2017 21:12:17 GMT
Repository: beam
Updated Branches:
  refs/heads/master b263cb776 -> f55d00253


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/master
Commit: f55d00253ef63adb96f96b0491b79d1024b905b6
Parents: b263cb7 9edd859
Author: Thomas Groh <tgroh@google.com>
Authored: Wed May 3 14:12:05 2017 -0700
Committer: Thomas Groh <tgroh@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(-)
----------------------------------------------------------------------



Mime
View raw message