beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [3/3] beam git commit: This closes #2938
Date Tue, 09 May 2017 16:36:31 GMT
This closes #2938


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

Branch: refs/heads/release-2.0.0
Commit: f7e85e2306c6ba04f8ff9feab999e14baf07e26e
Parents: bad377c 3a4ffd2
Author: Dan Halperin <dhalperi@google.com>
Authored: Tue May 9 09:36:24 2017 -0700
Committer: Dan Halperin <dhalperi@google.com>
Committed: Tue May 9 09:36:24 2017 -0700

----------------------------------------------------------------------
 .../apache/beam/runners/core/LateDataUtils.java |   2 +-
 .../beam/runners/flink/FlinkRunnerResult.java   |   8 +-
 .../metrics/DoFnRunnerWithMetricsUpdate.java    |  12 +-
 .../flink/metrics/FlinkMetricContainer.java     | 273 +++--------
 .../flink/metrics/FlinkMetricResults.java       | 146 ------
 .../flink/metrics/MetricsAccumulator.java       |  60 +++
 .../flink/metrics/ReaderInvocationUtil.java     |   7 +-
 .../translation/wrappers/SourceInputFormat.java |   8 +-
 .../streaming/io/BoundedSourceWrapper.java      |   8 +-
 .../streaming/io/UnboundedSourceWrapper.java    |   9 +-
 .../beam/runners/spark/SparkPipelineResult.java |   8 +-
 .../apache/beam/runners/spark/io/SourceRDD.java |   4 +-
 .../runners/spark/io/SparkUnboundedSource.java  |  19 +-
 .../spark/metrics/MetricsAccumulator.java       |  20 +-
 .../spark/metrics/MetricsAccumulatorParam.java  |  20 +-
 .../runners/spark/metrics/SparkBeamMetric.java  |  11 +-
 .../spark/metrics/SparkBeamMetricSource.java    |   2 +-
 .../spark/metrics/SparkMetricResults.java       | 172 -------
 .../spark/metrics/SparkMetricsContainer.java    | 174 -------
 .../SparkGroupAlsoByWindowViaWindowSet.java     |   4 +-
 .../spark/stateful/StateSpecFunctions.java      |   8 +-
 .../translation/DoFnRunnerWithMetrics.java      |   6 +-
 .../spark/translation/MultiDoFnFunction.java    |   6 +-
 .../spark/translation/TransformTranslator.java  |   4 +-
 .../streaming/StreamingTransformTranslator.java |   4 +-
 .../apache/beam/sdk/metrics/CounterCell.java    |  27 +-
 .../org/apache/beam/sdk/metrics/DirtyState.java |   3 +-
 .../beam/sdk/metrics/DistributionCell.java      |  16 +-
 .../org/apache/beam/sdk/metrics/GaugeCell.java  |  20 +-
 .../org/apache/beam/sdk/metrics/MetricCell.java |  14 +-
 .../org/apache/beam/sdk/metrics/Metrics.java    |   2 +-
 .../beam/sdk/metrics/MetricsContainer.java      |  29 +-
 .../sdk/metrics/MetricsContainerStepMap.java    | 487 +++++++++++++++++++
 .../org/apache/beam/sdk/metrics/MetricsMap.java |   5 +-
 .../beam/sdk/metrics/CounterCellTest.java       |   6 +-
 .../metrics/MetricsContainerStepMapTest.java    | 258 ++++++++++
 .../beam/sdk/metrics/MetricsContainerTest.java  |  14 +-
 37 files changed, 1086 insertions(+), 790 deletions(-)
----------------------------------------------------------------------



Mime
View raw message