beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tg...@apache.org
Subject [1/2] incubator-beam git commit: This closes #1424
Date Mon, 28 Nov 2016 18:06:45 GMT
Repository: incubator-beam
Updated Branches:
  refs/heads/master 9fbd2d24e -> 5e9a80cf6


This closes #1424


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

Branch: refs/heads/master
Commit: 5e9a80cf61c4666edb5febd9a0fface2d2c26261
Parents: 9fbd2d2 7502add
Author: Thomas Groh <tgroh@google.com>
Authored: Mon Nov 28 10:06:31 2016 -0800
Committer: Thomas Groh <tgroh@google.com>
Committed: Mon Nov 28 10:06:31 2016 -0800

----------------------------------------------------------------------
 .../direct/AbstractModelEnforcement.java        |  2 +-
 .../direct/BoundedReadEvaluatorFactory.java     |  2 +-
 .../beam/runners/direct/CommittedResult.java    |  2 +-
 .../beam/runners/direct/CompletionCallback.java |  2 +-
 ...ecycleManagerRemovingTransformEvaluator.java |  2 +-
 .../runners/direct/EmptyTransformEvaluator.java |  4 +-
 .../beam/runners/direct/EvaluationContext.java  |  2 +-
 .../direct/ExecutorServiceParallelExecutor.java |  2 +-
 .../runners/direct/FlattenEvaluatorFactory.java | 10 ++---
 .../GroupAlsoByWindowEvaluatorFactory.java      |  5 ++-
 .../direct/GroupByKeyOnlyEvaluatorFactory.java  |  2 +-
 .../direct/ImmutabilityEnforcementFactory.java  |  2 +-
 .../beam/runners/direct/ModelEnforcement.java   |  2 +-
 .../beam/runners/direct/ParDoEvaluator.java     |  2 +-
 .../direct/PassthroughTransformEvaluator.java   |  4 +-
 .../runners/direct/StepTransformResult.java     | 38 +++++++++--------
 .../direct/TestStreamEvaluatorFactory.java      |  2 +-
 .../beam/runners/direct/TransformEvaluator.java |  2 +-
 .../beam/runners/direct/TransformExecutor.java  |  4 +-
 .../beam/runners/direct/TransformResult.java    | 16 +++++--
 .../direct/UnboundedReadEvaluatorFactory.java   |  3 +-
 .../runners/direct/ViewEvaluatorFactory.java    |  2 +-
 .../runners/direct/WindowEvaluatorFactory.java  |  6 ++-
 .../direct/BoundedReadEvaluatorFactoryTest.java | 10 ++---
 ...leManagerRemovingTransformEvaluatorTest.java |  4 +-
 .../runners/direct/EvaluationContextTest.java   | 20 ++++-----
 .../direct/FlattenEvaluatorFactoryTest.java     |  6 +--
 .../ImmutabilityEnforcementFactoryTest.java     |  6 +--
 .../beam/runners/direct/ParDoEvaluatorTest.java |  2 +-
 .../runners/direct/StepTransformResultTest.java | 25 ++++++-----
 .../direct/TestStreamEvaluatorFactoryTest.java  | 10 ++---
 .../runners/direct/TransformExecutorTest.java   | 45 ++++++++++----------
 .../UnboundedReadEvaluatorFactoryTest.java      | 20 ++++++---
 .../direct/WindowEvaluatorFactoryTest.java      | 12 +++---
 34 files changed, 152 insertions(+), 126 deletions(-)
----------------------------------------------------------------------



Mime
View raw message