Package | Description |
---|---|
org.apache.flink.dropwizard.metrics | |
org.apache.flink.metrics | |
org.apache.flink.metrics.datadog | |
org.apache.flink.metrics.groups | |
org.apache.flink.metrics.reporter | |
org.apache.flink.metrics.testutils | |
org.apache.flink.python.metric | |
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.internals.metrics | |
org.apache.flink.streaming.runtime.io | |
org.apache.flink.streaming.runtime.metrics | |
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
org.apache.flink.table.runtime.operators.window | |
org.apache.flink.table.runtime.operators.window.slicing |
Modifier and Type | Method and Description |
---|---|
static <T> FlinkGaugeWrapper<T> |
FlinkGaugeWrapper.fromGauge(Gauge<?> gauge) |
Constructor and Description |
---|
FlinkGaugeWrapper(Gauge<T> gauge) |
Modifier and Type | Method and Description |
---|---|
default <T,G extends Gauge<T>> |
MetricGroup.gauge(int name,
G gauge)
Registers a new
Gauge with Flink. |
<T,G extends Gauge<T>> |
MetricGroup.gauge(String name,
G gauge)
Registers a new
Gauge with Flink. |
Constructor and Description |
---|
DGauge(Gauge<Number> g,
String metricName,
String host,
List<String> tags,
Clock clock) |
Modifier and Type | Method and Description |
---|---|
<T,G extends Gauge<T>> |
UnregisteredMetricsGroup.gauge(String name,
G gauge) |
Modifier and Type | Field and Description |
---|---|
protected Map<Gauge<?>,String> |
AbstractReporter.gauges |
Modifier and Type | Method and Description |
---|---|
<T> Gauge<T> |
MetricListener.getGauge(String... identifier)
Get registered
Gauge with identifier relative to the root metric 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 |
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 |
---|---|
MetricDumpSerialization.MetricSerializationResult |
MetricDumpSerialization.MetricDumpSerializer.serialize(Map<Counter,Tuple2<QueryScopeInfo,String>> counters,
Map<Gauge<?>,Tuple2<QueryScopeInfo,String>> gauges,
Map<Histogram,Tuple2<QueryScopeInfo,String>> histograms,
Map<Meter,Tuple2<QueryScopeInfo,String>> meters)
Serializes the given metrics and returns the resulting byte array.
|
Modifier and Type | Method and Description |
---|---|
<T,G extends Gauge<T>> |
ProxyMetricGroup.gauge(String name,
G gauge) |
<T,G extends Gauge<T>> |
AbstractMetricGroup.gauge(String name,
G gauge) |
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 | Method and Description |
---|---|
Gauge<Long> |
RecordWriterOutput.getWatermarkGauge() |
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. |
Modifier and Type | Method and Description |
---|---|
Gauge<Long> |
WatermarkGaugeExposingOutput.getWatermarkGauge() |
Modifier and Type | Method and Description |
---|---|
protected Gauge<Long> |
WindowOperator.getWatermarkLatency() |
Modifier and Type | Method and Description |
---|---|
Gauge<Long> |
SlicingWindowOperator.getWatermarkLatency() |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.