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.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 |
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 |
---|---|
static void |
MetricQueryService.notifyOfAddedMetric(akka.actor.ActorRef service,
Metric metric,
String metricName,
AbstractMetricGroup group)
Utility method to notify a MetricQueryService of an added metric.
|
static void |
MetricQueryService.notifyOfRemovedMetric(akka.actor.ActorRef service,
Metric metric)
Utility method to notify a MetricQueryService of a removed 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.