Package org.apache.nemo.runtime.common.metric

Class StreamMetric

java.lang.Object

org.apache.nemo.runtime.common.metric.StreamMetric

All Implemented Interfaces:

java.io.Serializable

public final class StreamMetric
extends java.lang.Object
implements java.io.Serializable

Metrics associated with stream. It is periodically recorded.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
StreamMetric(long startTimeStamp, long endTimeStamp, long numOfTuples, long serializedReadBytes, boolean isReadNotSerializedData)

Method Summary

Modifier and Type	Method	Description
long	getEndTimeStamp()	Get endpoint of record period.
boolean	getIsReadNotSerializedData()	Get a boolean value that indicates whether it read data from local block or not.
long	getNumOfProcessedTuples()	Get the number of processed tuple.
long	getSerializedReadBytes()	Get the number of read bytes.
long	getStartTimeStamp()	Get starting point of record period.

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamMetric

public StreamMetric(long startTimeStamp,
                    long endTimeStamp,
                    long numOfTuples,
                    long serializedReadBytes,
                    boolean isReadNotSerializedData)

Parameters:

startTimeStamp - the starting point from which metric is recorded.

endTimeStamp - the endpoint from which metric is recorded.

numOfTuples - the number of tuples processed between starting point and endpoint.

serializedReadBytes - the number of read bytes processed between starting point and endpoint.

isReadNotSerializedData - whether the task read data from local block or not.

Method Detail

getStartTimeStamp

public long getStartTimeStamp()

Get starting point of record period.

Returns:

start timestamp.

getEndTimeStamp

public long getEndTimeStamp()

Get endpoint of record period.

Returns:

end timestamp.

getNumOfProcessedTuples

public long getNumOfProcessedTuples()

Get the number of processed tuple.

Returns:

number of tuples.

getSerializedReadBytes

public long getSerializedReadBytes()

Get the number of read bytes.

Returns:

number of read bytes.

getIsReadNotSerializedData

public boolean getIsReadNotSerializedData()

Get a boolean value that indicates whether it read data from local block or not.

Returns:

a boolean value that indicates whether it read data form local block or not.