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 #411
Date Thu, 02 Jun 2016 00:57:04 GMT
Closes #411


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1da797d8
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1da797d8
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/1da797d8

Branch: refs/heads/master
Commit: 1da797d8f5dfae73cd7574c2d388e9ba3317a839
Parents: b9a8cbe e3cc4fa
Author: Dan Halperin <dhalperi@google.com>
Authored: Wed Jun 1 17:56:38 2016 -0700
Committer: Dan Halperin <dhalperi@google.com>
Committed: Wed Jun 1 17:56:38 2016 -0700

----------------------------------------------------------------------
 .../beam/runners/direct/BundleFactory.java      |  4 +-
 .../direct/ExecutorServiceParallelExecutor.java |  8 +-
 .../ImmutabilityCheckingBundleFactory.java      |  4 +-
 .../direct/InMemoryWatermarkManager.java        | 70 ++++++++-------
 .../runners/direct/InProcessBundleFactory.java  | 25 +++---
 .../direct/InProcessEvaluationContext.java      | 10 +--
 .../direct/InProcessExecutionContext.java       |  4 +-
 ...InProcessGroupByKeyOnlyEvaluatorFactory.java |  6 +-
 .../runners/direct/InProcessPipelineRunner.java |  7 +-
 .../apache/beam/runners/direct/StepAndKey.java  |  8 +-
 .../beam/runners/direct/StructuralKey.java      | 77 ++++++++++++++++
 .../direct/GroupByKeyEvaluatorFactoryTest.java  | 27 ++++--
 .../ImmutabilityCheckingBundleFactoryTest.java  | 13 ++-
 .../direct/InMemoryWatermarkManagerTest.java    | 95 +++++++++++---------
 .../direct/InProcessBundleFactoryTest.java      | 54 ++++++-----
 .../direct/InProcessEvaluationContextTest.java  | 52 ++++++-----
 ...ocessGroupByKeyOnlyEvaluatorFactoryTest.java | 33 ++++---
 .../direct/InProcessPipelineRunnerTest.java     | 60 +++++++++++++
 .../direct/InProcessTimerInternalsTest.java     |  3 +-
 .../direct/ParDoInProcessEvaluatorTest.java     |  2 +-
 .../direct/ParDoMultiEvaluatorFactoryTest.java  | 29 +++---
 .../direct/ParDoSingleEvaluatorFactoryTest.java | 35 +++++---
 .../beam/runners/direct/StructuralKeyTest.java  | 81 +++++++++++++++++
 23 files changed, 500 insertions(+), 207 deletions(-)
----------------------------------------------------------------------



Mime
View raw message