You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2016/06/16 02:30:47 UTC
[12/12] incubator-beam git commit: This closes #474
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 <kl...@google.com>
Authored: Wed Jun 15 19:29:17 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
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(-)
----------------------------------------------------------------------