You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by dh...@apache.org on 2016/03/15 19:23:58 UTC
[3/3] incubator-beam git commit: Closes #11
Closes #11
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/46412e5f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/46412e5f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/46412e5f
Branch: refs/heads/master
Commit: 46412e5f2b0c5cc341aaa741f979abddb91a7dd9
Parents: 7f9270e 53db159
Author: Dan Halperin <dh...@google.com>
Authored: Tue Mar 15 11:23:50 2016 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Tue Mar 15 11:23:50 2016 -0700
----------------------------------------------------------------------
.../inprocess/BoundedReadEvaluatorFactory.java | 1 -
.../sdk/runners/inprocess/EvaluatorKey.java | 1 -
.../inprocess/FlattenEvaluatorFactory.java | 1 -
.../inprocess/GroupByKeyEvaluatorFactory.java | 1 -
.../inprocess/InMemoryWatermarkManager.java | 14 +-
.../sdk/runners/inprocess/InProcessBundle.java | 20 +-
.../inprocess/InProcessEvaluationContext.java | 364 ++++++++++++++++
.../inprocess/InProcessPipelineOptions.java | 7 +-
.../inprocess/InProcessPipelineRunner.java | 106 +----
.../inprocess/InProcessSideInputContainer.java | 71 ++-
.../inprocess/ParDoMultiEvaluatorFactory.java | 1 -
.../inprocess/ParDoSingleEvaluatorFactory.java | 1 -
.../sdk/runners/inprocess/StepAndKey.java | 68 +++
.../inprocess/TransformEvaluatorFactory.java | 1 -
.../inprocess/TransformEvaluatorRegistry.java | 72 +++
.../UnboundedReadEvaluatorFactory.java | 1 -
.../runners/inprocess/ViewEvaluatorFactory.java | 1 -
.../inprocess/WatermarkCallbackExecutor.java | 143 ++++++
.../BoundedReadEvaluatorFactoryTest.java | 2 +-
.../inprocess/FlattenEvaluatorFactoryTest.java | 1 -
.../GroupByKeyEvaluatorFactoryTest.java | 1 -
.../inprocess/InMemoryWatermarkManagerTest.java | 12 +
.../InProcessEvaluationContextTest.java | 436 +++++++++++++++++++
.../InProcessSideInputContainerTest.java | 92 ++--
.../ParDoMultiEvaluatorFactoryTest.java | 1 -
.../ParDoSingleEvaluatorFactoryTest.java | 1 -
.../UnboundedReadEvaluatorFactoryTest.java | 1 -
.../inprocess/ViewEvaluatorFactoryTest.java | 1 -
.../WatermarkCallbackExecutorTest.java | 126 ++++++
29 files changed, 1372 insertions(+), 176 deletions(-)
----------------------------------------------------------------------