org.apache.flink.runtime.executiongraph

Class IOMetrics

java.lang.Object

org.apache.flink.runtime.executiongraph.IOMetrics

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

MutableIOMetrics

public class IOMetrics
extends Object
implements Serializable

An instance of this class represents a snapshot of the io-related metrics of a single task.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected long	numBytesInLocal
protected double	numBytesInLocalPerSecond
protected long	numBytesInRemote
protected double	numBytesInRemotePerSecond
protected long	numBytesOut
protected double	numBytesOutPerSecond
protected long	numRecordsIn
protected double	numRecordsInPerSecond
protected long	numRecordsOut
protected double	numRecordsOutPerSecond

Constructor Summary

Constructors

Constructor and Description
IOMetrics(long numBytesInLocal, long numBytesInRemote, long numBytesOut, long numRecordsIn, long numRecordsOut, double numBytesInLocalPerSecond, double numBytesInRemotePerSecond, double numBytesOutPerSecond, double numRecordsInPerSecond, double numRecordsOutPerSecond)
IOMetrics(Meter recordsIn, Meter recordsOut, Meter bytesLocalIn, Meter bytesRemoteIn, Meter bytesOut)

Method Summary

Modifier and Type	Method and Description
long	getNumBytesInLocal()
double	getNumBytesInLocalPerSecond()
long	getNumBytesInRemote()
double	getNumBytesInRemotePerSecond()
long	getNumBytesInTotal()
long	getNumBytesOut()
double	getNumBytesOutPerSecond()
long	getNumRecordsIn()
double	getNumRecordsInPerSecond()
long	getNumRecordsOut()
double	getNumRecordsOutPerSecond()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

numRecordsIn

protected long numRecordsIn

numRecordsOut

protected long numRecordsOut

numRecordsInPerSecond

protected double numRecordsInPerSecond

numRecordsOutPerSecond

protected double numRecordsOutPerSecond

numBytesInLocal

protected long numBytesInLocal

numBytesInRemote

protected long numBytesInRemote

numBytesOut

protected long numBytesOut

numBytesInLocalPerSecond

protected double numBytesInLocalPerSecond

numBytesInRemotePerSecond

protected double numBytesInRemotePerSecond

numBytesOutPerSecond

protected double numBytesOutPerSecond

Constructor Detail

IOMetrics

public IOMetrics(Meter recordsIn,
                 Meter recordsOut,
                 Meter bytesLocalIn,
                 Meter bytesRemoteIn,
                 Meter bytesOut)

IOMetrics

public IOMetrics(long numBytesInLocal,
                 long numBytesInRemote,
                 long numBytesOut,
                 long numRecordsIn,
                 long numRecordsOut,
                 double numBytesInLocalPerSecond,
                 double numBytesInRemotePerSecond,
                 double numBytesOutPerSecond,
                 double numRecordsInPerSecond,
                 double numRecordsOutPerSecond)

Method Detail

getNumRecordsIn

public long getNumRecordsIn()

getNumRecordsOut

public long getNumRecordsOut()

getNumBytesInLocal

public long getNumBytesInLocal()

getNumBytesInRemote

public long getNumBytesInRemote()

getNumBytesInTotal

public long getNumBytesInTotal()

getNumBytesOut

public long getNumBytesOut()

getNumRecordsInPerSecond

public double getNumRecordsInPerSecond()

getNumRecordsOutPerSecond

public double getNumRecordsOutPerSecond()

getNumBytesInLocalPerSecond

public double getNumBytesInLocalPerSecond()

getNumBytesInRemotePerSecond

public double getNumBytesInRemotePerSecond()

getNumBytesOutPerSecond

public double getNumBytesOutPerSecond()