beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [3/3] incubator-beam git commit: Closes #11
Date Tue, 15 Mar 2016 18:23:58 GMT
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 <dhalperi@google.com>
Authored: Tue Mar 15 11:23:50 2016 -0700
Committer: Dan Halperin <dhalperi@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(-)
----------------------------------------------------------------------



Mime
View raw message