Uses of Interface
org.apache.flink.runtime.taskmanager.TaskActions

Packages that use TaskActions

Package	Description
org.apache.flink.runtime.io.network.partition
org.apache.flink.runtime.taskexecutor.rpc
org.apache.flink.runtime.taskmanager

Uses of TaskActions in org.apache.flink.runtime.io.network.partition

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

Modifier and Type	Method and Description
void	ResultPartitionConsumableNotifier.notifyPartitionConsumable(JobID jobId, ResultPartitionID partitionId, TaskActions taskActions)

Uses of TaskActions in org.apache.flink.runtime.taskexecutor.rpc

Methods in org.apache.flink.runtime.taskexecutor.rpc with parameters of type TaskActions

Modifier and Type	Method and Description
void	RpcResultPartitionConsumableNotifier.notifyPartitionConsumable(JobID jobId, ResultPartitionID partitionId, TaskActions taskActions)

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

Classes in org.apache.flink.runtime.taskmanager that implement TaskActions

Modifier and Type	Class and Description
class	NoOpTaskActions A dummy implementation of the TaskActions which is mainly used for tests.
class	Task The Task represents one execution of a parallel subtask on a TaskManager.

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

Modifier and Type

Method and Description

static ResultPartitionWriter[]

ConsumableNotifyingResultPartitionWriterDecorator.decorate(Collection<ResultPartitionDeploymentDescriptor> descs, ResultPartitionWriter[] partitionWriters, TaskActions taskActions, JobID jobId, ResultPartitionConsumableNotifier notifier) Optionally decorate the ResultPartitionWriter to call ResultPartitionConsumableNotifier.notifyPartitionConsumable(JobID, ResultPartitionID, TaskActions) on the first record, iff ResultPartitionDeploymentDescriptor.notifyPartitionDataAvailable() is true.