org.apache.flink.metrics.groups

Interface SinkCommitterMetricGroup

All Superinterfaces:

MetricGroup, OperatorMetricGroup

All Known Implementing Classes:

InternalSinkCommitterMetricGroup

@PublicEvolving
public interface SinkCommitterMetricGroup
extends OperatorMetricGroup

Pre-defined metrics for sinks.

You should only update the metrics in the main operator thread.

Method Summary

Modifier and Type	Method and Description
Counter	getNumCommittablesAlreadyCommittedCounter() The total number of already committed committables.
Counter	getNumCommittablesFailureCounter() The total number of committable failures.
Counter	getNumCommittablesRetryCounter() The total number of committable retry.
Counter	getNumCommittablesSuccessCounter() The total number of successful committables.
Counter	getNumCommittablesTotalCounter() The total number of committables arrived.
void	setCurrentPendingCommittablesGauge(Gauge<Integer> currentPendingCommittablesGauge) The pending committables.

Methods inherited from interface org.apache.flink.metrics.groups.OperatorMetricGroup

getIOMetricGroup

Methods inherited from interface org.apache.flink.metrics.MetricGroup

addGroup, addGroup, addGroup, addSpan, counter, counter, counter, counter, gauge, gauge, getAllVariables, getMetricIdentifier, getMetricIdentifier, getScopeComponents, histogram, histogram, meter, meter

Method Detail

getNumCommittablesTotalCounter

Counter getNumCommittablesTotalCounter()

The total number of committables arrived.

getNumCommittablesFailureCounter

Counter getNumCommittablesFailureCounter()

The total number of committable failures.

getNumCommittablesRetryCounter

Counter getNumCommittablesRetryCounter()

The total number of committable retry.

getNumCommittablesSuccessCounter

Counter getNumCommittablesSuccessCounter()

The total number of successful committables.

getNumCommittablesAlreadyCommittedCounter

Counter getNumCommittablesAlreadyCommittedCounter()

The total number of already committed committables.

setCurrentPendingCommittablesGauge

void setCurrentPendingCommittablesGauge(Gauge<Integer> currentPendingCommittablesGauge)

The pending committables.