Clean up per worker histogram reporting path (#34244)
Co-authored-by: 
Naireen <naireenhussain@google.com>
显示
- runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowMetricsContainer.java 5 个添加, 6 个删除...eam/runners/dataflow/worker/DataflowMetricsContainer.java
- runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingStepMetricsContainer.java 28 个添加, 21 个删除...unners/dataflow/worker/StreamingStepMetricsContainer.java
- runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/StreamingStepMetricsContainerTest.java 22 个添加, 10 个删除...rs/dataflow/worker/StreamingStepMetricsContainerTest.java
- runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/streaming/StageInfoTest.java 1 个添加, 1 个删除...beam/runners/dataflow/worker/streaming/StageInfoTest.java
- sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/DelegatingHistogram.java 1 个添加, 24 个删除...java/org/apache/beam/sdk/metrics/DelegatingHistogram.java
- sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricsContainer.java 0 个添加, 9 个删除...in/java/org/apache/beam/sdk/metrics/MetricsContainer.java
- sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/NoOpGauge.java 0 个添加, 42 个删除.../src/main/java/org/apache/beam/sdk/metrics/NoOpGauge.java
- sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQuerySinkMetrics.java 3 个添加, 1 个删除.../apache/beam/sdk/io/gcp/bigquery/BigQuerySinkMetrics.java
- sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQuerySinkMetricsTest.java 14 个添加, 4 个删除...che/beam/sdk/io/gcp/bigquery/BigQuerySinkMetricsTest.java
- sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/StreamingInsertsMetricsTest.java 5 个添加, 1 个删除...beam/sdk/io/gcp/bigquery/StreamingInsertsMetricsTest.java
- sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaSinkMetrics.java 3 个添加, 2 个删除...n/java/org/apache/beam/sdk/io/kafka/KafkaSinkMetrics.java
- sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaMetricsTest.java 13 个添加, 11 个删除...t/java/org/apache/beam/sdk/io/kafka/KafkaMetricsTest.java
- sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaSinkMetricsTest.java 4 个添加, 1 个删除...va/org/apache/beam/sdk/io/kafka/KafkaSinkMetricsTest.java
加载中