You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by da...@apache.org on 2016/11/24 00:03:11 UTC
[11/11] incubator-beam git commit: This closes #1432
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 <da...@google.com>
Authored: Wed Nov 23 16:02:41 2016 -0800
Committer: Davor Bonaci <da...@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(-)
----------------------------------------------------------------------