Package org.apache.flink.runtime.rest.messages.job.metrics

Class IOMetricsInfo

java.lang.Object

org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

public final class IOMetricsInfo
extends java.lang.Object

IO metrics information.

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	FIELD_NAME_ACC_BACK_PRESSURE
static java.lang.String	FIELD_NAME_ACC_BUSY
static java.lang.String	FIELD_NAME_ACC_IDLE
static java.lang.String	FIELD_NAME_BYTES_READ
static java.lang.String	FIELD_NAME_BYTES_WRITTEN
static java.lang.String	FIELD_NAME_RECORDS_READ
static java.lang.String	FIELD_NAME_RECORDS_WRITTEN

Constructor Summary

Constructors

Constructor	Description
IOMetricsInfo(long bytesRead, boolean bytesReadComplete, long bytesWritten, boolean bytesWrittenComplete, long recordsRead, boolean recordsReadComplete, long recordsWritten, boolean recordsWrittenComplete, java.lang.Long accumulatedBackpressured, java.lang.Long accumulatedIdle, java.lang.Double accumulatedBusy)

Method Summary

Modifier and Type	Method	Description
boolean	equals(java.lang.Object o)
long	getAccumulatedBackpressured()
double	getAccumulatedBusy()
long	getAccumulatedIdle()
long	getBytesRead()
long	getBytesWritten()
long	getRecordsRead()
long	getRecordsWritten()
int	hashCode()
boolean	isBytesReadComplete()
boolean	isBytesWrittenComplete()
boolean	isRecordsReadComplete()
boolean	isRecordsWrittenComplete()

Methods inherited from class java.lang.Object

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

Field Detail

FIELD_NAME_BYTES_READ

public static final java.lang.String FIELD_NAME_BYTES_READ

See Also:

Constant Field Values

FIELD_NAME_BYTES_WRITTEN

public static final java.lang.String FIELD_NAME_BYTES_WRITTEN

See Also:

Constant Field Values

FIELD_NAME_RECORDS_READ

public static final java.lang.String FIELD_NAME_RECORDS_READ

See Also:

Constant Field Values

FIELD_NAME_RECORDS_WRITTEN

public static final java.lang.String FIELD_NAME_RECORDS_WRITTEN

See Also:

Constant Field Values

FIELD_NAME_ACC_BACK_PRESSURE

public static final java.lang.String FIELD_NAME_ACC_BACK_PRESSURE

See Also:

Constant Field Values

FIELD_NAME_ACC_IDLE

public static final java.lang.String FIELD_NAME_ACC_IDLE

See Also:

Constant Field Values

FIELD_NAME_ACC_BUSY

public static final java.lang.String FIELD_NAME_ACC_BUSY

See Also:

Constant Field Values

Constructor Detail

IOMetricsInfo

public IOMetricsInfo(long bytesRead,
                     boolean bytesReadComplete,
                     long bytesWritten,
                     boolean bytesWrittenComplete,
                     long recordsRead,
                     boolean recordsReadComplete,
                     long recordsWritten,
                     boolean recordsWrittenComplete,
                     java.lang.Long accumulatedBackpressured,
                     java.lang.Long accumulatedIdle,
                     java.lang.Double accumulatedBusy)

Method Detail

getBytesRead

public long getBytesRead()

isBytesReadComplete

public boolean isBytesReadComplete()

getBytesWritten

public long getBytesWritten()

isBytesWrittenComplete

public boolean isBytesWrittenComplete()

getRecordsRead

public long getRecordsRead()

isRecordsReadComplete

public boolean isRecordsReadComplete()

getRecordsWritten

public long getRecordsWritten()

isRecordsWrittenComplete

public boolean isRecordsWrittenComplete()

getAccumulatedBackpressured

public long getAccumulatedBackpressured()

getAccumulatedBusy

public double getAccumulatedBusy()

getAccumulatedIdle

public long getAccumulatedIdle()

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object