Uses of Interface
org.apache.flink.metrics.Gauge

Packages that use Gauge

Package	Description
org.apache.flink.metrics
org.apache.flink.metrics.groups
org.apache.flink.metrics.reporter

Uses of Gauge in org.apache.flink.metrics

Methods in org.apache.flink.metrics with type parameters of type Gauge

Modifier and Type	Method and Description
default <T,G extends Gauge<T>> G	MetricGroup.gauge(int name, G gauge) Registers a new Gauge with Flink.
<T,G extends Gauge<T>> G	MetricGroup.gauge(String name, G gauge) Registers a new Gauge with Flink.

Uses of Gauge in org.apache.flink.metrics.groups

Methods in org.apache.flink.metrics.groups with type parameters of type Gauge

Modifier and Type	Method and Description
<T,G extends Gauge<T>> G	UnregisteredMetricsGroup.gauge(String name, G gauge)
<G extends Gauge<Long>> G	SplitEnumeratorMetricGroup.setUnassignedSplitsGauge(G unassignedSplitsGauge) Sets an optional gauge for the number of splits that have been enumerated but not yet assigned.

Methods in org.apache.flink.metrics.groups with parameters of type Gauge

Modifier and Type	Method and Description
void	CacheMetricGroup.latestLoadTimeGauge(Gauge<Long> latestLoadTimeGauge) The time spent for the latest load operation.
void	CacheMetricGroup.numCachedBytesGauge(Gauge<Long> numCachedBytesGauge) The number of bytes used by cache.
void	CacheMetricGroup.numCachedRecordsGauge(Gauge<Long> numCachedRecordsGauge) The number of records in cache.
void	SinkWriterMetricGroup.setCurrentSendTimeGauge(Gauge<Long> currentSendTimeGauge) Sets an optional gauge for the time it takes to send the last record.
void	SourceReaderMetricGroup.setPendingBytesGauge(Gauge<Long> pendingBytesGauge) Sets an optional gauge for the number of bytes that have not been fetched by the source.
void	SourceReaderMetricGroup.setPendingRecordsGauge(Gauge<Long> pendingRecordsGauge) Sets an optional gauge for the number of records that have not been fetched by the source.

Uses of Gauge in org.apache.flink.metrics.reporter

Fields in org.apache.flink.metrics.reporter with type parameters of type Gauge

Modifier and Type	Field and Description
protected Map<Gauge<?>,String>	AbstractReporter.gauges