Uses of Class
org.apache.flink.runtime.event.task.AbstractEvent

Packages that use AbstractEvent

Package	Description
org.apache.flink.runtime.event.task
org.apache.flink.runtime.io.network.api
org.apache.flink.runtime.io.network.api.reader
org.apache.flink.runtime.io.network.api.serialization
org.apache.flink.runtime.io.network.api.writer
org.apache.flink.runtime.io.network.partition.consumer
org.apache.flink.runtime.iterative.event

Uses of AbstractEvent in org.apache.flink.runtime.event.task

Subclasses of AbstractEvent in org.apache.flink.runtime.event.task

Modifier and Type	Class and Description
class	IntegerTaskEvent This class provides a simple implementation of an event that holds an integer value.
class	RuntimeEvent
class	StringTaskEvent This class provides a simple implementation of an event that holds a string value.
class	TaskEvent

Uses of AbstractEvent in org.apache.flink.runtime.io.network.api

Subclasses of AbstractEvent in org.apache.flink.runtime.io.network.api

Modifier and Type	Class and Description
class	EndOfPartitionEvent
class	EndOfSuperstepEvent Marks the end of a superstep of one particular iteration head

Uses of AbstractEvent in org.apache.flink.runtime.io.network.api.reader

Methods in org.apache.flink.runtime.io.network.api.reader with parameters of type AbstractEvent

Modifier and Type	Method and Description
protected boolean	AbstractReader.handleEvent(AbstractEvent event) Handles the event and returns whether the reader reached an end-of-stream event (either the end of the whole stream or the end of an superstep).

Uses of AbstractEvent in org.apache.flink.runtime.io.network.api.serialization

Methods in org.apache.flink.runtime.io.network.api.serialization that return AbstractEvent

Modifier and Type	Method and Description
static AbstractEvent	EventSerializer.fromBuffer(Buffer buffer, ClassLoader classLoader)
static AbstractEvent	EventSerializer.fromSerializedEvent(ByteBuffer buffer, ClassLoader classLoader)

Methods in org.apache.flink.runtime.io.network.api.serialization with parameters of type AbstractEvent

Modifier and Type	Method and Description
static Buffer	EventSerializer.toBuffer(AbstractEvent event)
static ByteBuffer	EventSerializer.toSerializedEvent(AbstractEvent event)

Uses of AbstractEvent in org.apache.flink.runtime.io.network.api.writer

Methods in org.apache.flink.runtime.io.network.api.writer with parameters of type AbstractEvent

Modifier and Type	Method and Description
void	RecordWriter.broadcastEvent(AbstractEvent event)
void	ResultPartitionWriter.writeEvent(AbstractEvent event, int targetChannel)
void	ResultPartitionWriter.writeEventToAllChannels(AbstractEvent event)

Uses of AbstractEvent in org.apache.flink.runtime.io.network.partition.consumer

Methods in org.apache.flink.runtime.io.network.partition.consumer that return AbstractEvent

Modifier and Type	Method and Description
AbstractEvent	BufferOrEvent.getEvent()

Constructors in org.apache.flink.runtime.io.network.partition.consumer with parameters of type AbstractEvent

Constructor and Description
BufferOrEvent(AbstractEvent event, int channelIndex)

Uses of AbstractEvent in org.apache.flink.runtime.iterative.event

Subclasses of AbstractEvent in org.apache.flink.runtime.iterative.event

Modifier and Type	Class and Description
class	AllWorkersDoneEvent
class	IterationEventWithAggregators
class	TerminationEvent Signals that the iteration is completely executed, participating tasks must terminate now
class	WorkerDoneEvent