Package org.apache.flink.runtime.metrics.groups

Class TaskIOMetricGroup

  • All Implemented Interfaces:
    MetricGroup
    public class TaskIOMetricGroup
extends ProxyMetricGroup<TaskMetricGroup>
    Metric group that contains shareable pre-defined IO-related metrics. The metrics registration is forwarded to the parent task metric group.

    • Method Detail

      • createSnapshot

        public IOMetrics createSnapshot()

      • getNumBytesInCounter

        public Counter getNumBytesInCounter()

      • getNumBytesOutCounter

        public Counter getNumBytesOutCounter()

      • getNumRecordsInCounter

        public Counter getNumRecordsInCounter()

      • getNumRecordsOutCounter

        public Counter getNumRecordsOutCounter()

      • getNumBuffersOutCounter

        public Counter getNumBuffersOutCounter()

      • getNumFiredTimers

        public Counter getNumFiredTimers()

      • getNumMailsProcessedCounter

        public Counter getNumMailsProcessedCounter()

      • getIdleTimeMsPerSecond

        public TimerGauge getIdleTimeMsPerSecond()

      • getSoftBackPressuredTimePerSecond

        public TimerGauge getSoftBackPressuredTimePerSecond()

      • getHardBackPressuredTimePerSecond

        public TimerGauge getHardBackPressuredTimePerSecond()

      • getChangelogBusyTimeMsPerSecond

        public TimerGauge getChangelogBusyTimeMsPerSecond()

      • getBackPressuredTimeMsPerSecond

        public long getBackPressuredTimeMsPerSecond()

      • getAccumulatedBackPressuredTimeMs

        public long getAccumulatedBackPressuredTimeMs()

      • markTaskStart

        public void markTaskStart()

      • markTaskInitializationStarted

        public void markTaskInitializationStarted()

      • getTaskInitializationDuration

        @VisibleForTesting
public long getTaskInitializationDuration()
        Returns the duration of time required for a task's restoring/initialization, which reaches its maximum when the task begins running and remains constant throughout the task's running. Return 0 when the task is not in initialization/running status.

      • setEnableBusyTime

        public void setEnableBusyTime​(boolean enabled)

      • getMailboxThroughput

        public Meter getMailboxThroughput()

      • getMailboxLatency

        public Histogram getMailboxLatency()

      • reuseBytesInputCounter

        public void reuseBytesInputCounter​(Counter numBytesInCounter)

      • reuseBytesOutputCounter

        public void reuseBytesOutputCounter​(Counter numBytesOutCounter)

      • reuseRecordsInputCounter

        public void reuseRecordsInputCounter​(Counter numRecordsInCounter)

      • reuseRecordsOutputCounter

        public void reuseRecordsOutputCounter​(Counter numRecordsOutCounter)