public class IOMetrics extends Object implements Serializable
Modifier and Type | Field and Description |
---|---|
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) |
IOMetrics(Meter recordsIn,
Meter recordsOut,
Meter bytesIn,
Meter bytesOut,
Map<IntermediateResultPartitionID,Counter> numBytesProducedCounters) |
Modifier and Type | Method and Description |
---|---|
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 final Map<IntermediateResultPartitionID,Long> numBytesProducedOfPartitions
public IOMetrics(Meter recordsIn, Meter recordsOut, Meter bytesIn, Meter bytesOut, Map<IntermediateResultPartitionID,Counter> numBytesProducedCounters)
public IOMetrics(long numBytesIn, long numBytesOut, long numRecordsIn, long numRecordsOut)
public long getNumRecordsIn()
public long getNumRecordsOut()
public long getNumBytesIn()
public long getNumBytesOut()
public Map<IntermediateResultPartitionID,Long> getNumBytesProducedOfPartitions()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.