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. |
class |
ThreadSafeSimpleCounter
A simple low-overhead
Counter that is 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 |
AbstractReporter.notifyOfAddedMetric(Metric metric,
String metricName,
MetricGroup group) |
void |
MetricReporter.notifyOfAddedMetric(Metric metric,
String metricName,
MetricGroup group)
Called when a new
Metric was added. |
void |
AbstractReporter.notifyOfRemovedMetric(Metric metric,
String metricName,
MetricGroup group) |
void |
MetricReporter.notifyOfRemovedMetric(Metric metric,
String metricName,
MetricGroup group)
Called when a
Metric was removed. |
Modifier and Type | Method and Description |
---|---|
<T extends Metric> |
MetricListener.getMetric(Class<T> metricType,
String... identifier)
Get registered
Metric with identifier relative to the root metric group. |
Modifier and Type | Method and Description |
---|---|
static MetricAssertions.CounterAssert |
MetricAssertions.assertThatCounter(Metric actual) |
static <T> MetricAssertions.GaugeAssert<T> |
MetricAssertions.assertThatGauge(Metric actual) |
Modifier and Type | Class and Description |
---|---|
class |
MetricDistribution
Flink
Gauge for Python Distribution. |
class |
MetricGauge
Flink
Gauge for Python Gauge. |
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 |
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 |
InputBuffersSizeGauge
Gauge metric measuring the size in bytes 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. |
class |
OutputBuffersSizeGauge
Gauge metric measuring the size in bytes of queued output buffers for
ResultPartition s. |
class |
TimeToConsumeGauge
Gauge metric measuring the maximal time to consume all buffers of all input gates.
|
Modifier and Type | Class and Description |
---|---|
class |
DescriptiveStatisticsHistogram
The
DescriptiveStatisticsHistogram use a DescriptiveStatistics DescriptiveStatistics as a Flink Histogram . |
class |
ThresholdMeter
A timestamp queue based threshold meter.
|
class |
TimerGauge
TimerGauge measures how much time is spent in a given state, with entry into that state
being signaled by TimerGauge.markStart() . |
Modifier and Type | Method and Description |
---|---|
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.register(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. |
void |
MetricRegistryImpl.unregister(Metric metric,
String metricName,
AbstractMetricGroup group) |
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 |
---|---|
boolean |
DefaultMetricFilter.filter(Metric metric,
String name,
String logicalScope) |
boolean |
MetricFilter.filter(Metric metric,
String name,
String logicalScope)
Filters a given 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.
|
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–2023 The Apache Software Foundation. All rights reserved.