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.runtime.executiongraph.metrics |
This package contains classes implementing various metrics for the job execution,
based on the
Execution Graph . |
org.apache.flink.runtime.metrics.dump | |
org.apache.flink.runtime.metrics.groups | |
org.apache.flink.streaming.api.collector.selector | |
org.apache.flink.streaming.connectors.kafka.internal.metrics | |
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.
|
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 |
---|---|
<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) |
Modifier and Type | Method and Description |
---|---|
<T,G extends Gauge<T>> |
UnregisteredMetricsGroup.gauge(int name,
G gauge) |
<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 | 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 | 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(int name,
G gauge) |
<T,G extends Gauge<T>> |
AbstractMetricGroup.gauge(int name,
G gauge) |
<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 | Method and Description |
---|---|
Gauge<Long> |
DirectedOutput.getWatermarkGauge() |
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 | Method and Description |
---|---|
Gauge<Long> |
RecordWriterOutput.getWatermarkGauge() |
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. |
Modifier and Type | Method and Description |
---|---|
Gauge<Long> |
OperatorChain.WatermarkGaugeExposingOutput.getWatermarkGauge() |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.