Uses of Class
org.apache.flink.runtime.event.TaskEvent

Packages that use TaskEvent

Package	Description
org.apache.flink.runtime.io.network
org.apache.flink.runtime.io.network.api
org.apache.flink.runtime.io.network.api.reader
org.apache.flink.runtime.io.network.netty
org.apache.flink.runtime.io.network.partition.consumer
org.apache.flink.runtime.iterative.concurrent
org.apache.flink.runtime.iterative.event
org.apache.flink.runtime.iterative.task
org.apache.flink.runtime.taskmanager

Uses of TaskEvent in org.apache.flink.runtime.io.network

Methods in org.apache.flink.runtime.io.network with parameters of type TaskEvent

Modifier and Type	Method and Description
boolean	TaskEventPublisher.publish(ResultPartitionID partitionId, TaskEvent event) Publishes the event to the registered EventListener instances.
boolean	TaskEventDispatcher.publish(ResultPartitionID partitionId, TaskEvent event) Publishes the event to the registered EventListener instances.
void	PartitionRequestClient.sendTaskEvent(ResultPartitionID partitionId, TaskEvent event, RemoteInputChannel inputChannel) Sends a task event backwards to an intermediate result partition.

Method parameters in org.apache.flink.runtime.io.network with type arguments of type TaskEvent

Modifier and Type	Method and Description
void	TaskEventDispatcher.subscribeToEvent(ResultPartitionID partitionId, EventListener<TaskEvent> eventListener, Class<? extends TaskEvent> eventType) Subscribes a listener to this dispatcher for events on a partition.
void	TaskEventDispatcher.subscribeToEvent(ResultPartitionID partitionId, EventListener<TaskEvent> eventListener, Class<? extends TaskEvent> eventType) Subscribes a listener to this dispatcher for events on a partition.

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

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

Modifier and Type	Method and Description
void	TaskEventHandler.publish(TaskEvent event) Publishes the task event to all subscribed event listeners.

Method parameters in org.apache.flink.runtime.io.network.api with type arguments of type TaskEvent

Modifier and Type	Method and Description
void	TaskEventHandler.subscribe(EventListener<TaskEvent> listener, Class<? extends TaskEvent> eventType)
void	TaskEventHandler.subscribe(EventListener<TaskEvent> listener, Class<? extends TaskEvent> eventType)

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

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

Modifier and Type	Method and Description
void	AbstractReader.publish(TaskEvent event)
void	AbstractReader.sendTaskEvent(TaskEvent event)
void	ReaderBase.sendTaskEvent(TaskEvent event)

Method parameters in org.apache.flink.runtime.io.network.api.reader with type arguments of type TaskEvent

Modifier and Type	Method and Description
void	AbstractReader.registerTaskEventListener(EventListener<TaskEvent> listener, Class<? extends TaskEvent> eventType)
void	AbstractReader.registerTaskEventListener(EventListener<TaskEvent> listener, Class<? extends TaskEvent> eventType)
void	ReaderBase.registerTaskEventListener(EventListener<TaskEvent> listener, Class<? extends TaskEvent> eventType)
void	ReaderBase.registerTaskEventListener(EventListener<TaskEvent> listener, Class<? extends TaskEvent> eventType)

Uses of TaskEvent in org.apache.flink.runtime.io.network.netty

Methods in org.apache.flink.runtime.io.network.netty with parameters of type TaskEvent

Modifier and Type	Method and Description
void	NettyPartitionRequestClient.sendTaskEvent(ResultPartitionID partitionId, TaskEvent event, RemoteInputChannel inputChannel) Sends a task event backwards to an intermediate result partition producer.

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

Methods in org.apache.flink.runtime.io.network.partition.consumer with parameters of type TaskEvent

Modifier and Type	Method and Description
void	SingleInputGate.sendTaskEvent(TaskEvent event)
abstract void	InputGate.sendTaskEvent(TaskEvent event)
void	UnionInputGate.sendTaskEvent(TaskEvent event)

Uses of TaskEvent in org.apache.flink.runtime.iterative.concurrent

Methods in org.apache.flink.runtime.iterative.concurrent with parameters of type TaskEvent

Modifier and Type	Method and Description
void	SuperstepBarrier.onEvent(TaskEvent event) Barrier will release the waiting thread if an event occurs.

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

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

Modifier and Type	Class and Description
class	AllWorkersDoneEvent Event sent by the IterationSynchronizationSinkTask to each IterationHead signaling to start a new superstep.
class	IterationEventWithAggregators Base class for iteration TaskEvent transmitting operator aggregators.
class	TerminationEvent Signals that the iteration is completely executed, participating tasks must terminate now.
class	WorkerDoneEvent Completion event sent from each IterationHead to the IterationSynchronizationSinkTask.

Uses of TaskEvent in org.apache.flink.runtime.iterative.task

Methods in org.apache.flink.runtime.iterative.task with parameters of type TaskEvent

Modifier and Type	Method and Description
void	SyncEventHandler.onEvent(TaskEvent event)

Uses of TaskEvent in org.apache.flink.runtime.taskmanager

Methods in org.apache.flink.runtime.taskmanager with parameters of type TaskEvent

Modifier and Type	Method and Description
void	InputGateWithMetrics.sendTaskEvent(TaskEvent event)