You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by bc...@apache.org on 2016/10/13 22:39:38 UTC
[5/5] incubator-beam git commit: Closes #1024
Closes #1024
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3c731707
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/3c731707
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/3c731707
Branch: refs/heads/master
Commit: 3c731707b2d986e7a460907c8f64bbebf1dff714
Parents: e969f3d 834933c
Author: bchambers <bc...@google.com>
Authored: Thu Oct 13 15:29:30 2016 -0700
Committer: bchambers <bc...@google.com>
Committed: Thu Oct 13 15:29:30 2016 -0700
----------------------------------------------------------------------
.../beam/runners/direct/DirectMetrics.java | 331 +++++++++++++++++++
.../beam/runners/direct/DirectRunner.java | 11 +-
.../beam/runners/direct/EvaluationContext.java | 10 +
.../direct/ExecutorServiceParallelExecutor.java | 1 +
.../direct/ImmutableListBundleFactory.java | 10 +
.../runners/direct/StepTransformResult.java | 49 ++-
.../beam/runners/direct/TransformExecutor.java | 35 +-
.../beam/runners/direct/TransformResult.java | 12 +
.../beam/runners/direct/DirectMetricsTest.java | 133 ++++++++
.../beam/runners/direct/DirectRunnerTest.java | 36 ++
.../runners/direct/TransformExecutorTest.java | 12 +
.../beam/runners/flink/FlinkRunnerResult.java | 6 +
.../runners/dataflow/DataflowPipelineJob.java | 7 +
.../spark/translation/EvaluationContext.java | 6 +
.../org/apache/beam/sdk/PipelineResult.java | 11 +
.../beam/sdk/annotations/Experimental.java | 3 +
.../org/apache/beam/sdk/metrics/Counter.java | 40 +++
.../apache/beam/sdk/metrics/CounterCell.java | 76 +++++
.../org/apache/beam/sdk/metrics/DirtyState.java | 98 ++++++
.../apache/beam/sdk/metrics/Distribution.java | 30 ++
.../beam/sdk/metrics/DistributionCell.java | 58 ++++
.../beam/sdk/metrics/DistributionData.java | 59 ++++
.../beam/sdk/metrics/DistributionResult.java | 42 +++
.../org/apache/beam/sdk/metrics/Metric.java | 24 ++
.../org/apache/beam/sdk/metrics/MetricCell.java | 47 +++
.../org/apache/beam/sdk/metrics/MetricKey.java | 40 +++
.../org/apache/beam/sdk/metrics/MetricName.java | 46 +++
.../beam/sdk/metrics/MetricNameFilter.java | 60 ++++
.../beam/sdk/metrics/MetricQueryResults.java | 33 ++
.../apache/beam/sdk/metrics/MetricResult.java | 45 +++
.../apache/beam/sdk/metrics/MetricResults.java | 34 ++
.../apache/beam/sdk/metrics/MetricUpdates.java | 72 ++++
.../org/apache/beam/sdk/metrics/Metrics.java | 110 ++++++
.../beam/sdk/metrics/MetricsContainer.java | 150 +++++++++
.../beam/sdk/metrics/MetricsEnvironment.java | 85 +++++
.../apache/beam/sdk/metrics/MetricsFilter.java | 86 +++++
.../org/apache/beam/sdk/metrics/MetricsMap.java | 86 +++++
.../apache/beam/sdk/metrics/package-info.java | 28 ++
.../beam/sdk/metrics/CounterCellTest.java | 55 +++
.../apache/beam/sdk/metrics/DirtyStateTest.java | 56 ++++
.../beam/sdk/metrics/DistributionCellTest.java | 53 +++
.../apache/beam/sdk/metrics/MetricMatchers.java | 99 ++++++
.../beam/sdk/metrics/MetricsContainerTest.java | 129 ++++++++
.../sdk/metrics/MetricsEnvironmentTest.java | 63 ++++
.../apache/beam/sdk/metrics/MetricsMapTest.java | 103 ++++++
.../apache/beam/sdk/metrics/MetricsTest.java | 98 ++++++
46 files changed, 2645 insertions(+), 33 deletions(-)
----------------------------------------------------------------------