org.apache.flink.runtime.event.job

Class AbstractEvent

java.lang.Object

org.apache.flink.runtime.event.job.AbstractEvent

All Implemented Interfaces:

Serializable, org.apache.flink.core.io.IOReadableWritable

public abstract class AbstractEvent
extends Object
implements org.apache.flink.core.io.IOReadableWritable, Serializable

An abstract event is transmitted from the job manager to the job client in order to inform the user about the job progress

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
AbstractEvent() Constructs a new abstract event object.
AbstractEvent(long timestamp) Constructs a new abstract event object.

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object obj)
long	getSequenceNumber()
long	getTimestamp() Returns the timestamp of the event.
String	getTimestampString()
int	hashCode()
void	read(org.apache.flink.core.memory.DataInputView in)
static String	timestampToString(long timestamp) Converts the timestamp of an event from its "milliseconds since beginning the epoch" representation into a unified string representation.
String	toString()
void	write(org.apache.flink.core.memory.DataOutputView out)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractEvent

public AbstractEvent()

Constructs a new abstract event object. This constructor is required for the deserialization process and is not supposed to be called directly.

AbstractEvent

public AbstractEvent(long timestamp)

Constructs a new abstract event object.

Parameters:

timestamp - the timestamp of the event.

Method Detail

getTimestamp

public long getTimestamp()

Returns the timestamp of the event.

Returns:

the timestamp of the event

getTimestampString

public String getTimestampString()

getSequenceNumber

public long getSequenceNumber()

read

public void read(org.apache.flink.core.memory.DataInputView in)
          throws IOException

Specified by:

read in interface org.apache.flink.core.io.IOReadableWritable

Throws:

IOException

write

public void write(org.apache.flink.core.memory.DataOutputView out)
           throws IOException

Specified by:

write in interface org.apache.flink.core.io.IOReadableWritable

Throws:

IOException

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

timestampToString

public static String timestampToString(long timestamp)

Converts the timestamp of an event from its "milliseconds since beginning the epoch" representation into a unified string representation.

Parameters:

timestamp - the timestamp in milliseconds since the beginning of "the epoch"

Returns:

the string unified representation of the timestamp