public class TaskIOMetricGroup extends ProxyMetricGroup<TaskMetricGroup>
parentMetricGroup
Constructor and Description |
---|
TaskIOMetricGroup(TaskMetricGroup parent) |
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 Counter getNumMailsProcessedCounter()
public TimerGauge getIdleTimeMsPerSecond()
public TimerGauge getSoftBackPressuredTimePerSecond()
public TimerGauge getHardBackPressuredTimePerSecond()
public long getBackPressuredTimeMsPerSecond()
public long getAccumulatedBackPressuredTimeMs()
public void markTaskStart()
public void setEnableBusyTime(boolean enabled)
public Meter getMailboxThroughput()
public Histogram getMailboxLatency()
public void reuseRecordsInputCounter(Counter numRecordsInCounter)
public void reuseRecordsOutputCounter(Counter numRecordsOutCounter)
public void registerNumBytesProducedCounterForPartition(IntermediateResultPartitionID resultPartitionId, Counter numBytesProducedCounter)
public void registerMailboxSizeSupplier(TaskIOMetricGroup.SizeGauge.SizeSupplier<Integer> supplier)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.