@Internal public class InternalOperatorIOMetricGroup extends ProxyMetricGroup<InternalOperatorMetricGroup> implements OperatorIOMetricGroup
parentMetricGroup
Constructor and Description |
---|
InternalOperatorIOMetricGroup(InternalOperatorMetricGroup parentMetricGroup) |
Modifier and Type | Method and Description |
---|---|
Counter |
getNumBytesInCounter()
The total number of input bytes since the task started.
|
Counter |
getNumBytesOutCounter()
The total number of output bytes since the task started.
|
Counter |
getNumRecordsInCounter()
The total number of input records since the operator started.
|
Meter |
getNumRecordsInRateMeter() |
Counter |
getNumRecordsOutCounter()
The total number of output records since the operator started.
|
Meter |
getNumRecordsOutRate() |
void |
reuseInputMetricsForTask()
Causes the containing task to use this operators input record counter.
|
void |
reuseOutputMetricsForTask()
Causes the containing task to use this operators output record counter.
|
addGroup, addGroup, counter, counter, gauge, getAllVariables, getMetricIdentifier, getMetricIdentifier, getScopeComponents, histogram, meter
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addGroup, addGroup, addGroup, counter, counter, counter, counter, gauge, gauge, getAllVariables, getMetricIdentifier, getMetricIdentifier, getScopeComponents, histogram, histogram, meter, meter
public InternalOperatorIOMetricGroup(InternalOperatorMetricGroup parentMetricGroup)
public Counter getNumRecordsInCounter()
OperatorIOMetricGroup
getNumRecordsInCounter
in interface OperatorIOMetricGroup
public Counter getNumRecordsOutCounter()
OperatorIOMetricGroup
getNumRecordsOutCounter
in interface OperatorIOMetricGroup
public Meter getNumRecordsInRateMeter()
public Meter getNumRecordsOutRate()
public Counter getNumBytesInCounter()
OperatorIOMetricGroup
getNumBytesInCounter
in interface OperatorIOMetricGroup
public Counter getNumBytesOutCounter()
OperatorIOMetricGroup
getNumBytesOutCounter
in interface OperatorIOMetricGroup
public void reuseInputMetricsForTask()
public void reuseOutputMetricsForTask()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.