Interface OperatorIOMetricGroup

  • All Superinterfaces:
    MetricGroup

    @PublicEvolving
    public interface OperatorIOMetricGroup
    extends MetricGroup
    Metric group that contains shareable pre-defined IO-related metrics for operators.

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

    • Method Detail

      • getNumRecordsInCounter

        Counter getNumRecordsInCounter()
        The total number of input records since the operator started. Will also populate numRecordsInPerSecond meter.
      • getNumRecordsOutCounter

        Counter getNumRecordsOutCounter()
        The total number of output records since the operator started. Will also populate numRecordsOutPerSecond meter.
      • getNumBytesInCounter

        Counter getNumBytesInCounter()
        The total number of input bytes since the task started. Will also populate numBytesInPerSecond meter.
      • getNumBytesOutCounter

        Counter getNumBytesOutCounter()
        The total number of output bytes since the task started. Will also populate numBytesOutPerSecond meter.