beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bchamb...@apache.org
Subject [5/5] incubator-beam git commit: Closes #1024
Date Thu, 13 Oct 2016 22:39:38 GMT
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 <bchambers@google.com>
Authored: Thu Oct 13 15:29:30 2016 -0700
Committer: bchambers <bchambers@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(-)
----------------------------------------------------------------------



Mime
View raw message