Package | Description |
---|---|
org.apache.flink.dropwizard | |
org.apache.flink.dropwizard.metrics | |
org.apache.flink.metrics | |
org.apache.flink.metrics.datadog | |
org.apache.flink.metrics.jmx | |
org.apache.flink.metrics.prometheus | |
org.apache.flink.metrics.reporter | |
org.apache.flink.runtime.executiongraph.metrics |
This package contains classes implementing various metrics for the job execution,
based on the
Execution Graph . |
org.apache.flink.runtime.io.network.metrics | |
org.apache.flink.runtime.metrics | |
org.apache.flink.runtime.metrics.dump | |
org.apache.flink.runtime.metrics.groups | |
org.apache.flink.streaming.connectors.kafka.internal.metrics | |
org.apache.flink.streaming.connectors.kafka.internals.metrics | |
org.apache.flink.streaming.runtime.metrics |
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 |
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 should be removed. |
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 |
NumberOfFullRestartsGauge
Gauge which returns the number of full restarts.
|
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 |
InputBufferPoolUsageGauge
Gauge metric measuring the input buffer pool 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 a WatermarkGauge pair. |
class |
WatermarkGauge
A
Gauge for exposing the current input/output watermark. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.