public class IOMetrics extends Object implements Serializable
Modifier and Type | Field and Description |
---|---|
protected long |
accumulateBackPressuredTime |
protected double |
accumulateBusyTime |
protected long |
accumulateIdleTime |
protected long |
numBytesIn |
protected long |
numBytesOut |
protected Map<IntermediateResultPartitionID,Long> |
numBytesProducedOfPartitions |
protected long |
numRecordsIn |
protected long |
numRecordsOut |
Constructor and Description |
---|
IOMetrics(long numBytesIn,
long numBytesOut,
long numRecordsIn,
long numRecordsOut,
long accumulateIdleTime,
long accumulateBusyTime,
long accumulateBackPressuredTime) |
IOMetrics(Meter recordsIn,
Meter recordsOut,
Meter bytesIn,
Meter bytesOut,
Map<IntermediateResultPartitionID,Counter> numBytesProducedCounters,
Gauge<Long> accumulatedBackPressuredTime,
Gauge<Long> accumulatedIdleTime,
Gauge<Double> accumulatedBusyTime) |
Modifier and Type | Method and Description |
---|---|
long |
getAccumulateBackPressuredTime() |
double |
getAccumulateBusyTime() |
long |
getAccumulateIdleTime() |
long |
getNumBytesIn() |
long |
getNumBytesOut() |
Map<IntermediateResultPartitionID,Long> |
getNumBytesProducedOfPartitions() |
long |
getNumRecordsIn() |
long |
getNumRecordsOut() |
protected long numRecordsIn
protected long numRecordsOut
protected long numBytesIn
protected long numBytesOut
protected long accumulateBackPressuredTime
protected double accumulateBusyTime
protected long accumulateIdleTime
protected final Map<IntermediateResultPartitionID,Long> numBytesProducedOfPartitions
public IOMetrics(Meter recordsIn, Meter recordsOut, Meter bytesIn, Meter bytesOut, Map<IntermediateResultPartitionID,Counter> numBytesProducedCounters, Gauge<Long> accumulatedBackPressuredTime, Gauge<Long> accumulatedIdleTime, Gauge<Double> accumulatedBusyTime)
public IOMetrics(long numBytesIn, long numBytesOut, long numRecordsIn, long numRecordsOut, long accumulateIdleTime, long accumulateBusyTime, long accumulateBackPressuredTime)
public long getNumRecordsIn()
public long getNumRecordsOut()
public long getNumBytesIn()
public long getNumBytesOut()
public double getAccumulateBusyTime()
public long getAccumulateBackPressuredTime()
public long getAccumulateIdleTime()
public Map<IntermediateResultPartitionID,Long> getNumBytesProducedOfPartitions()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.