beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [1/5] incubator-beam git commit: Closes #690
Date Mon, 15 Aug 2016 21:17:06 GMT
Repository: incubator-beam
Updated Branches:
  refs/heads/master 0b1f66421 -> 7c680079b


Closes #690


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

Branch: refs/heads/master
Commit: 7c680079b5074ff31257d7f8fff77af1dd9ea62c
Parents: 0b1f664 29cbdce
Author: Dan Halperin <dhalperi@google.com>
Authored: Mon Aug 15 14:16:54 2016 -0700
Committer: Dan Halperin <dhalperi@google.com>
Committed: Mon Aug 15 14:16:54 2016 -0700

----------------------------------------------------------------------
 .../direct/BoundedReadEvaluatorFactory.java     |   4 +
 .../beam/runners/direct/CloningThreadLocal.java |  43 --
 .../runners/direct/DoFnLifecycleManager.java    | 106 +++++
 ...ecycleManagerRemovingTransformEvaluator.java |  79 ++++
 .../runners/direct/DoFnLifecycleManagers.java   |  45 ++
 .../direct/ExecutorServiceParallelExecutor.java |   9 +-
 .../runners/direct/FlattenEvaluatorFactory.java |   3 +
 .../GroupAlsoByWindowEvaluatorFactory.java      |   6 +-
 .../direct/GroupByKeyOnlyEvaluatorFactory.java  |   4 +-
 .../direct/ParDoMultiEvaluatorFactory.java      |  55 ++-
 .../direct/ParDoSingleEvaluatorFactory.java     |  42 +-
 ...readLocalInvalidatingTransformEvaluator.java |  63 ---
 .../direct/TransformEvaluatorFactory.java       |   8 +
 .../direct/TransformEvaluatorRegistry.java      |  41 ++
 .../direct/UnboundedReadEvaluatorFactory.java   |   3 +
 .../runners/direct/ViewEvaluatorFactory.java    |   3 +
 .../runners/direct/WindowEvaluatorFactory.java  |   3 +
 .../runners/direct/CloningThreadLocalTest.java  |  92 ----
 ...leManagerRemovingTransformEvaluatorTest.java | 144 ++++++
 .../direct/DoFnLifecycleManagerTest.java        | 168 +++++++
 .../direct/DoFnLifecycleManagersTest.java       | 142 ++++++
 ...LocalInvalidatingTransformEvaluatorTest.java | 135 ------
 .../functions/FlinkDoFnFunction.java            |  12 +-
 .../functions/FlinkMultiOutputDoFnFunction.java |  31 +-
 .../streaming/FlinkAbstractParDoWrapper.java    |   2 +
 .../FlinkGroupAlsoByWindowWrapper.java          |   2 +
 runners/google-cloud-dataflow-java/pom.xml      |  10 +
 .../runners/spark/translation/DoFnFunction.java |  23 +-
 .../spark/translation/MultiDoFnFunction.java    |   1 +
 .../spark/translation/SparkProcessContext.java  |  17 +
 .../org/apache/beam/sdk/transforms/DoFn.java    |  31 +-
 .../beam/sdk/transforms/DoFnReflector.java      |  70 ++-
 .../org/apache/beam/sdk/transforms/OldDoFn.java |  25 ++
 .../org/apache/beam/sdk/transforms/ParDo.java   |  15 +-
 .../beam/sdk/transforms/DoFnReflectorTest.java  |  65 +++
 .../beam/sdk/transforms/ParDoLifecycleTest.java | 448 +++++++++++++++++++
 .../apache/beam/sdk/transforms/ParDoTest.java   |  15 +-
 37 files changed, 1553 insertions(+), 412 deletions(-)
----------------------------------------------------------------------



Mime
View raw message