Modifier and Type | Method and Description |
---|---|
void |
ChangelogStorageMetricGroup.registerUploadQueueSizeGauge(Gauge<Integer> gauge) |
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) |
<G extends Gauge<Long>> |
SplitEnumeratorMetricGroup.setUnassignedSplitsGauge(G unassignedSplitsGauge)
Sets an optional gauge for the number of splits that have been enumerated but not yet
assigned.
|
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.
|
Modifier and Type | Field and Description |
---|---|
protected Map<Gauge<?>,String> |
AbstractReporter.gauges |
Modifier and Type | Method and Description |
---|---|
<T> Optional<Gauge<T>> |
MetricListener.getGauge(String... identifier)
Get registered
Gauge with identifier relative to the root metric group. |
Modifier and Type | Class and Description |
---|---|
class |
MetricDistribution
Flink
Gauge for Python Distribution. |
class |
MetricGauge
Flink
Gauge for Python Gauge. |
Modifier and Type | Class and Description |
---|---|
static class |
FlinkMetricContainer.FlinkDistributionGauge
Flink
Gauge for DistributionResult . |
static class |
FlinkMetricContainer.FlinkGauge
Flink
Gauge for GaugeResult . |
Constructor and Description |
---|
IOMetrics(Meter recordsIn,
Meter recordsOut,
Meter bytesIn,
Meter bytesOut,
Map<IntermediateResultPartitionID,Counter> numBytesProducedCounters,
Gauge<Long> accumulatedBackPressuredTime,
Gauge<Long> accumulatedIdleTime,
Gauge<Double> accumulatedBusyTime) |
IOMetrics(Meter recordsIn,
Meter recordsOut,
Meter bytesIn,
Meter bytesOut,
Map<IntermediateResultPartitionID,Counter> numBytesProducedCounters,
Gauge<Long> accumulatedBackPressuredTime,
Gauge<Long> accumulatedIdleTime,
Gauge<Double> accumulatedBusyTime) |
IOMetrics(Meter recordsIn,
Meter recordsOut,
Meter bytesIn,
Meter bytesOut,
Map<IntermediateResultPartitionID,Counter> numBytesProducedCounters,
Gauge<Long> accumulatedBackPressuredTime,
Gauge<Long> accumulatedIdleTime,
Gauge<Double> accumulatedBusyTime) |
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 |
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 |
InputBuffersSizeGauge
Gauge metric measuring the size in bytes 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. |
class |
OutputBuffersSizeGauge
Gauge metric measuring the size in bytes of queued output buffers for
ResultPartition s. |
class |
TimeToConsumeGauge
Gauge metric measuring the maximal time to consume all buffers of all input gates.
|
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 | Method and Description |
---|---|
Gauge<Integer> |
TaskIOMetricGroup.getMailboxSize() |
Modifier and Type | Method and Description |
---|---|
void |
InternalCacheMetricGroup.latestLoadTimeGauge(Gauge<Long> latestLoadTimeGauge) |
void |
InternalCacheMetricGroup.numCachedBytesGauge(Gauge<Long> numCachedBytesGauge) |
void |
InternalCacheMetricGroup.numCachedRecordsGauge(Gauge<Long> numCachedRecordsGauge) |
void |
InternalSinkWriterMetricGroup.setCurrentSendTimeGauge(Gauge<Long> currentSendTimeGauge) |
void |
InternalSourceReaderMetricGroup.setPendingBytesGauge(Gauge<Long> pendingBytesGauge) |
void |
InternalSourceReaderMetricGroup.setPendingRecordsGauge(Gauge<Long> pendingRecordsGauge) |
Modifier and Type | Method and Description |
---|---|
static void |
SchedulerBase.registerJobMetrics(MetricGroup metrics,
JobStatusProvider jobStatusProvider,
Gauge<Long> numberOfRestarts,
DeploymentStateTimeMetrics deploymentTimeMetrics,
java.util.function.Consumer<JobStatusListener> jobStatusListenerRegistrar,
long initializationTimestamp,
MetricOptions.JobStatusMetricsSettings jobStatusMetricsSettings) |
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> |
FinishedOnRestoreMainOperatorOutput.getWatermarkGauge() |
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.