Package org.apache.flink.runtime.taskmanager

Interface Summary

Interface	Description
CheckpointResponder	Responder for checkpoint acknowledge and decline messages in the Task.
TaskActions	Actions which can be performed on a Task.
TaskExecutionStateListener
TaskManagerActions	Interface for the communication of the Task with the TaskManager.
TaskManagerRuntimeInfo	Interface to access TaskManager information.

Class Summary

Class	Description
ActorGatewayCheckpointResponder	Implementation using ActorGateway to forward the messages.
ActorGatewayKvStateLocationOracle	KvStateLocationOracle implementation for ActorGateway.
ActorGatewayKvStateRegistryListener	This implementation uses ActorGateway to forward key-value state notifications to the job manager.
ActorGatewayPartitionProducerStateChecker	This implementation uses ActorGateway to trigger the partition state check at the job manager.
ActorGatewayResultPartitionConsumableNotifier	This implementation uses ActorGateway to notify the job manager about consumable partitions.
ActorGatewayTaskExecutionStateListener	Implementation using ActorGateway to forward the messages.
ActorGatewayTaskManagerActions	Implementation using ActorGateway to forward the messages.
DispatcherThreadFactory	Thread factory that creates threads with a given name, associates them with a given thread group, and set them to daemon mode.
MemoryLogger	A thread the periodically logs statistics about: Heap and non-heap memory usage Memory pools and pool usage Garbage collection times and counts
NetworkEnvironmentConfiguration	Configuration object for the network stack.
RuntimeEnvironment	In implementation of the Environment.
Task	The Task represents one execution of a parallel subtask on a TaskManager.
TaskExecutionState	This class represents an update about a task's execution state.
TaskInputSplitProvider	Implementation using ActorGateway to forward the messages.
TaskManager	A Taskmanager in the same package as the proper Flink TaskManager.
TaskManagerCliOptions	The command line parameters passed to the TaskManager.
TaskManagerLocation	This class encapsulates the connection information of a TaskManager.