beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From da...@apache.org
Subject [11/11] incubator-beam git commit: This closes #1432
Date Thu, 24 Nov 2016 00:03:11 GMT
This closes #1432


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

Branch: refs/heads/python-sdk
Commit: 3dbeb8edfdfe4c9e8987e4d8df4451fdb748dc07
Parents: 9b9d016 2e03bb8
Author: Davor Bonaci <davor@google.com>
Authored: Wed Nov 23 16:02:41 2016 -0800
Committer: Davor Bonaci <davor@google.com>
Committed: Wed Nov 23 16:02:41 2016 -0800

----------------------------------------------------------------------
 runners/apex/pom.xml                            |   7 +-
 .../translation/ParDoBoundMultiTranslator.java  |  67 +++++----
 .../apex/translation/ParDoBoundTranslator.java  |  46 +++---
 .../beam/runners/direct/DirectRunner.java       |   5 +-
 .../GroupAlsoByWindowEvaluatorFactory.java      |   4 +-
 .../beam/runners/direct/TransformExecutor.java  |   5 +-
 runners/flink/runner/pom.xml                    |   1 +
 .../FlinkBatchTransformTranslators.java         |  34 ++++-
 .../FlinkStreamingTransformTranslators.java     |  25 +++-
 runners/spark/pom.xml                           |   1 +
 .../spark/translation/TransformTranslator.java  |  23 +++
 .../beam/sdk/metrics/MetricsEnvironment.java    |  60 ++++++--
 .../beam/sdk/testing/UsesStatefulParDo.java     |  25 ++++
 .../beam/sdk/util/common/ReflectHelpers.java    |   3 +-
 .../sdk/metrics/MetricsEnvironmentTest.java     |   8 +-
 .../apache/beam/sdk/metrics/MetricsTest.java    |   6 +-
 .../sdk/runners/TransformHierarchyTest.java     | 142 +++++++++++++++++++
 .../src/main/java/StarterPipeline.java          |  18 +--
 .../src/main/java/it/pkg/StarterPipeline.java   |  18 +--
 19 files changed, 407 insertions(+), 91 deletions(-)
----------------------------------------------------------------------



Mime
View raw message