Class EventAnnouncement
- java.lang.Object
-
- org.apache.flink.runtime.event.AbstractEvent
-
- org.apache.flink.runtime.event.RuntimeEvent
-
- org.apache.flink.runtime.io.network.api.EventAnnouncement
-
- All Implemented Interfaces:
IOReadableWritable
public class EventAnnouncement extends RuntimeEvent
EventAnnouncement
is announcing presence or receiving of anAbstractEvent
. ThatannouncedEvent
is identified by it's sequence number.
-
-
Constructor Summary
Constructors Constructor Description EventAnnouncement(AbstractEvent announcedEvent, int sequenceNumber)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(Object other)
AbstractEvent
getAnnouncedEvent()
int
getSequenceNumber()
int
hashCode()
void
read(DataInputView in)
Reads the object's internal data from the given data input view.String
toString()
void
write(DataOutputView out)
Writes the object's internal data to the given data output view.
-
-
-
Constructor Detail
-
EventAnnouncement
public EventAnnouncement(AbstractEvent announcedEvent, int sequenceNumber)
-
-
Method Detail
-
getAnnouncedEvent
public AbstractEvent getAnnouncedEvent()
-
getSequenceNumber
public int getSequenceNumber()
-
write
public void write(DataOutputView out) throws IOException
Description copied from interface:IOReadableWritable
Writes the object's internal data to the given data output view.- Parameters:
out
- the output view to receive the data.- Throws:
IOException
- thrown if any error occurs while writing to the output stream
-
read
public void read(DataInputView in) throws IOException
Description copied from interface:IOReadableWritable
Reads the object's internal data from the given data input view.- Parameters:
in
- the input view to read the data from- Throws:
IOException
- thrown if any error occurs while reading from the input stream
-
-