SinkCommitterMetricGroup (Flink : Metrics : Core 2.1.2-cp1 API)

All Superinterfaces:

MetricGroup, OperatorMetricGroup
```
@PublicEvolving
public interface SinkCommitterMetricGroup
extends OperatorMetricGroup
```
Pre-defined metrics for sinks.
You should only update the metrics in the main operator thread.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	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.MetricGroup
addEvent, addGroup, addGroup, addGroup, addSpan, counter, counter, counter, counter, gauge, gauge, getAllVariables, getMetricIdentifier, getMetricIdentifier, getScopeComponents, histogram, histogram, meter, meter

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

- 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.