beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [12/12] incubator-beam git commit: This closes #474
Date Thu, 16 Jun 2016 02:30:47 GMT
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 <klk@google.com>
Authored: Wed Jun 15 19:29:17 2016 -0700
Committer: Kenneth Knowles <klk@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(-)
----------------------------------------------------------------------



Mime
View raw message