Interface | Description |
---|---|
CheckpointResponder |
Responder for checkpoint acknowledge and decline messages in the
Task . |
TaskActions |
Actions which can be performed on a
Task . |
TaskExecutionStateListener | |
TaskManagerConnection |
Interface for the communication of the
Task with the TaskManager . |
Class | Description |
---|---|
ActorGatewayCheckpointResponder |
Implementation using
ActorGateway to forward the messages. |
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. |
ActorGatewayTaskManagerConnection |
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 | |
NetworkEnvironmentConfiguration$ | |
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 |
The TaskManager is responsible for executing the individual tasks of a Flink job.
|
TaskManager$ |
TaskManager companion object.
|
TaskManagerCliOptions |
The command line parameters passed to the TaskManager.
|
TaskManagerConfiguration | |
TaskManagerConfiguration$ | |
TaskManagerLocation |
This class encapsulates the connection information of a TaskManager.
|
TaskManagerRuntimeInfo |
Encapsulation of TaskManager runtime information, like hostname and configuration.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.