Modifier and Type | Method and Description |
---|---|
void |
ScheduledDropwizardReporter.notifyOfAddedMetric(Metric metric,
String metricName,
MetricGroup group) |
void |
ScheduledDropwizardReporter.notifyOfRemovedMetric(Metric metric,
String metricName,
MetricGroup group) |
Modifier and Type | Class and Description |
---|---|
class |
DropwizardHistogramWrapper
Wrapper to use a Dropwizard
Histogram as a Flink Histogram . |
class |
DropwizardMeterWrapper
Wrapper to use a Dropwizard
Meter as a Flink Meter . |
Modifier and Type | Interface and Description |
---|---|
interface |
Counter
A Counter is a
Metric that measures a count. |
interface |
Gauge<T>
A Gauge is a
Metric that calculates a specific value at a point in time. |
interface |
Histogram
Histogram interface to be used with Flink's metrics system.
|
interface |
Meter
Metric for measuring throughput.
|
Modifier and Type | Class and Description |
---|---|
class |
MeterView
A MeterView provides an average rate of events per second over a given time period.
|
class |
SimpleCounter
A simple low-overhead
Counter that is not thread-safe. |
Modifier and Type | Method and Description |
---|---|
void |
DatadogHttpReporter.notifyOfAddedMetric(Metric metric,
String metricName,
MetricGroup group) |
void |
DatadogHttpReporter.notifyOfRemovedMetric(Metric metric,
String metricName,
MetricGroup group) |
Modifier and Type | Method and Description |
---|---|
void |
JMXReporter.notifyOfAddedMetric(Metric metric,
String metricName,
MetricGroup group) |
void |
JMXReporter.notifyOfRemovedMetric(Metric metric,
String metricName,
MetricGroup group) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractPrometheusReporter.notifyOfAddedMetric(Metric metric,
String metricName,
MetricGroup group) |
void |
AbstractPrometheusReporter.notifyOfRemovedMetric(Metric metric,
String metricName,
MetricGroup group) |
Modifier and Type | Method and Description |
---|---|
void |
MetricReporter.notifyOfAddedMetric(Metric metric,
String metricName,
MetricGroup group)
Called when a new
Metric was added. |
void |
AbstractReporter.notifyOfAddedMetric(Metric metric,
String metricName,
MetricGroup group) |
void |
MetricReporter.notifyOfRemovedMetric(Metric metric,
String metricName,
MetricGroup group)
Called when a
Metric was removed. |
void |
AbstractReporter.notifyOfRemovedMetric(Metric metric,
String metricName,
MetricGroup group) |
Modifier and Type | Class and Description |
---|---|
static class |
FlinkMetricContainer.FlinkDistributionGauge
Flink
Gauge for DistributionResult . |
static class |
FlinkMetricContainer.FlinkGauge
Flink
Gauge for GaugeResult . |
Modifier and Type | Class and Description |
---|---|
class |
DownTimeGauge
A gauge that returns (in milliseconds) how long a job has not been not running any more, in case
it is in a failing/recovering situation.
|
class |
RestartTimeGauge
Gauge which returns the last restarting time.
|
class |
UpTimeGauge
A gauge that returns (in milliseconds) how long a job has been running.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractBuffersUsageGauge
Abstract gauge implementation for calculating the buffer usage percent.
|
class |
CreditBasedInputBuffersUsageGauge
Gauge metric measuring the input buffers usage for
SingleInputGate s under credit based
mode. |
class |
ExclusiveBuffersUsageGauge
Gauge metric measuring the exclusive buffers usage gauge for
SingleInputGate s. |
class |
FloatingBuffersUsageGauge
Gauge metric measuring the floating buffers usage gauge for
SingleInputGate s. |
class |
InputBuffersGauge
Gauge metric measuring the number of queued input buffers for
SingleInputGate s. |
class |
OutputBufferPoolUsageGauge
Gauge metric measuring the output buffer pool usage gauge for
ResultPartition s. |
class |
OutputBuffersGauge
Gauge metric measuring the number of queued output buffers for
ResultPartition s. |
Modifier and Type | Class and Description |
---|---|
class |
DescriptiveStatisticsHistogram
The
DescriptiveStatisticsHistogram use a DescriptiveStatistics DescriptiveStatistics as a Flink Histogram . |
Modifier and Type | Method and Description |
---|---|
void |
MetricRegistryImpl.register(Metric metric,
String metricName,
AbstractMetricGroup group) |
void |
NoOpMetricRegistry.register(Metric metric,
String metricName,
AbstractMetricGroup group) |
void |
MetricRegistry.register(Metric metric,
String metricName,
AbstractMetricGroup group)
Registers a new
Metric with this registry. |
void |
MetricRegistryImpl.unregister(Metric metric,
String metricName,
AbstractMetricGroup group) |
void |
NoOpMetricRegistry.unregister(Metric metric,
String metricName,
AbstractMetricGroup group) |
void |
MetricRegistry.unregister(Metric metric,
String metricName,
AbstractMetricGroup group)
Un-registers the given
Metric with this registry. |
Modifier and Type | Method and Description |
---|---|
void |
MetricQueryService.addMetric(String metricName,
Metric metric,
AbstractMetricGroup group) |
void |
MetricQueryService.removeMetric(Metric metric) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractMetricGroup.addMetric(String name,
Metric metric)
Adds the given metric to the group and registers it at the registry, if the group is not yet
closed, and if no metric with the same name has been registered before.
|
Modifier and Type | Class and Description |
---|---|
class |
KafkaMetricMutableWrapper
Gauge for getting the current value of a Kafka metric.
|
Modifier and Type | Class and Description |
---|---|
class |
KafkaMetricWrapper
Gauge for getting the current value of a Kafka metric.
|
Modifier and Type | Class and Description |
---|---|
class |
MinWatermarkGauge
A
Gauge for exposing the minimum watermark of chosen WatermarkGauge s. |
class |
WatermarkGauge
A
Gauge for exposing the current input/output watermark. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.