org.apache.flink.runtime.metrics.groups

Class InternalSinkCommitterMetricGroup

java.lang.Object

org.apache.flink.runtime.metrics.groups.ProxyMetricGroup<MetricGroup>

org.apache.flink.runtime.metrics.groups.InternalSinkCommitterMetricGroup

All Implemented Interfaces:

OperatorMetricGroup, SinkCommitterMetricGroup, MetricGroup

@Internal
public class InternalSinkCommitterMetricGroup
extends ProxyMetricGroup<MetricGroup>
implements SinkCommitterMetricGroup

Special MetricGroup representing an Operator.

Field Summary

Fields inherited from class org.apache.flink.runtime.metrics.groups.ProxyMetricGroup

parentMetricGroup

Method Summary

Modifier and Type	Method and Description
OperatorIOMetricGroup	getIOMetricGroup()
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.
static InternalSinkCommitterMetricGroup	wrap(OperatorMetricGroup operatorMetricGroup)

Methods inherited from class org.apache.flink.runtime.metrics.groups.ProxyMetricGroup

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

wrap

public static InternalSinkCommitterMetricGroup wrap(OperatorMetricGroup operatorMetricGroup)

getIOMetricGroup

public OperatorIOMetricGroup getIOMetricGroup()

Specified by:

getIOMetricGroup in interface OperatorMetricGroup

getNumCommittablesTotalCounter

public Counter getNumCommittablesTotalCounter()

Description copied from interface: SinkCommitterMetricGroup

The total number of committables arrived.

Specified by:

getNumCommittablesTotalCounter in interface SinkCommitterMetricGroup

getNumCommittablesFailureCounter

public Counter getNumCommittablesFailureCounter()

Description copied from interface: SinkCommitterMetricGroup

The total number of committable failures.

Specified by:

getNumCommittablesFailureCounter in interface SinkCommitterMetricGroup

getNumCommittablesRetryCounter

public Counter getNumCommittablesRetryCounter()

Description copied from interface: SinkCommitterMetricGroup

The total number of committable retry.

Specified by:

getNumCommittablesRetryCounter in interface SinkCommitterMetricGroup

getNumCommittablesSuccessCounter

public Counter getNumCommittablesSuccessCounter()

Description copied from interface: SinkCommitterMetricGroup

The total number of successful committables.

Specified by:

getNumCommittablesSuccessCounter in interface SinkCommitterMetricGroup

getNumCommittablesAlreadyCommittedCounter

public Counter getNumCommittablesAlreadyCommittedCounter()

Description copied from interface: SinkCommitterMetricGroup

The total number of already committed committables.

Specified by:

getNumCommittablesAlreadyCommittedCounter in interface SinkCommitterMetricGroup

setCurrentPendingCommittablesGauge

public void setCurrentPendingCommittablesGauge(Gauge<Integer> currentPendingCommittablesGauge)

Description copied from interface: SinkCommitterMetricGroup

The pending committables.

Specified by:

setCurrentPendingCommittablesGauge in interface SinkCommitterMetricGroup