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 Object

IO metrics information.

Constructor Summary

Constructors

Constructor and Description
IOMetricsInfo(long bytesRead, boolean bytesReadComplete, long bytesWritten, boolean bytesWrittenComplete, long recordsRead, boolean recordsReadComplete, long recordsWritten, boolean recordsWrittenComplete)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
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

Constructor Detail

IOMetricsInfo

public IOMetricsInfo(long bytesRead,
                     boolean bytesReadComplete,
                     long bytesWritten,
                     boolean bytesWrittenComplete,
                     long recordsRead,
                     boolean recordsReadComplete,
                     long recordsWritten,
                     boolean recordsWrittenComplete)

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()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object