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 <bchamb...@google.com> Authored: Thu Oct 13 15:29:30 2016 -0700 Committer: bchambers <bchamb...@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(-) ----------------------------------------------------------------------
