public class TaskIOMetricGroup extends ProxyMetricGroup<TaskMetricGroup>
parentMetricGroup
Constructor and Description |
---|
TaskIOMetricGroup(TaskMetricGroup parent) |
Modifier and Type | Method and Description |
---|---|
IOMetrics |
createSnapshot() |
long |
getBackPressuredTimeMsPerSecond() |
TimerGauge |
getHardBackPressuredTimePerSecond() |
TimerGauge |
getIdleTimeMsPerSecond() |
Counter |
getNumBuffersOutCounter() |
Counter |
getNumBytesInCounter() |
Counter |
getNumBytesOutCounter() |
Counter |
getNumRecordsInCounter() |
Counter |
getNumRecordsOutCounter() |
TimerGauge |
getSoftBackPressuredTimePerSecond() |
void |
registerNumBytesProducedCounterForPartition(IntermediateResultPartitionID resultPartitionId,
Counter numBytesProducedCounter) |
void |
reuseRecordsInputCounter(Counter numRecordsInCounter) |
void |
reuseRecordsOutputCounter(Counter numRecordsOutCounter) |
void |
setEnableBusyTime(boolean enabled) |
addGroup, addGroup, counter, counter, gauge, getAllVariables, getMetricIdentifier, getMetricIdentifier, getScopeComponents, histogram, meter
public TaskIOMetricGroup(TaskMetricGroup parent)
public IOMetrics createSnapshot()
public Counter getNumBytesInCounter()
public Counter getNumBytesOutCounter()
public Counter getNumRecordsInCounter()
public Counter getNumRecordsOutCounter()
public Counter getNumBuffersOutCounter()
public TimerGauge getIdleTimeMsPerSecond()
public TimerGauge getSoftBackPressuredTimePerSecond()
public TimerGauge getHardBackPressuredTimePerSecond()
public long getBackPressuredTimeMsPerSecond()
public void setEnableBusyTime(boolean enabled)
public void reuseRecordsInputCounter(Counter numRecordsInCounter)
public void reuseRecordsOutputCounter(Counter numRecordsOutCounter)
public void registerNumBytesProducedCounterForPartition(IntermediateResultPartitionID resultPartitionId, Counter numBytesProducedCounter)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.