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

All Superinterfaces:

MetricGroup, OperatorCoordinatorMetricGroup
```
@PublicEvolving
public interface SourceSplitMetricGroup
extends OperatorCoordinatorMetricGroup
```
Pre-defined metrics for SplitEnumerator.
You should only update the metrics in the main operator thread.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`double`	`getAccumulatedActiveTime()`
`long`	`getAccumulatedIdleTime()`
`long`	`getAccumulatedPausedTime()`
`double`	`getActiveTimePerSecond()`
`long`	`getCurrentWatermark()`
`long`	`getIdleTimePerSecond()`
`long`	`getPausedTimePerSecond()`

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

Method Detail

getCurrentWatermark
```
long getCurrentWatermark()
```

getActiveTimePerSecond
```
double getActiveTimePerSecond()
```

getPausedTimePerSecond
```
long getPausedTimePerSecond()
```

getIdleTimePerSecond
```
long getIdleTimePerSecond()
```

getAccumulatedActiveTime
```
double getAccumulatedActiveTime()
```

getAccumulatedPausedTime
```
long getAccumulatedPausedTime()
```

getAccumulatedIdleTime
```
long getAccumulatedIdleTime()
```