Class and Description |
---|
TaskManagerLocation
This class encapsulates the connection information of a TaskManager.
|
Class and Description |
---|
TaskManagerRuntimeInfo
Interface to access
TaskExecutor information. |
Class and Description |
---|
TaskExecutionState
This class represents an update about a task's execution state.
|
TaskManagerLocation
This class encapsulates the connection information of a TaskManager.
|
Class and Description |
---|
NettyShuffleEnvironmentConfiguration
Configuration object for the network stack.
|
TaskManagerLocation
This class encapsulates the connection information of a TaskManager.
|
Class and Description |
---|
NettyShuffleEnvironmentConfiguration
Configuration object for the network stack.
|
Class and Description |
---|
TaskExecutionState
This class represents an update about a task's execution state.
|
TaskManagerLocation
This class encapsulates the connection information of a TaskManager.
|
UnresolvedTaskManagerLocation
This class encapsulates the connection information of a TaskManager, without resolving the
hostname.
|
Class and Description |
---|
TaskManagerLocation
This class encapsulates the connection information of a TaskManager.
|
Class and Description |
---|
TaskManagerRuntimeInfo
Interface to access
TaskExecutor information. |
Class and Description |
---|
TaskExecutionState
This class represents an update about a task's execution state.
|
TaskManagerLocation
This class encapsulates the connection information of a TaskManager.
|
Class and Description |
---|
TaskManagerLocation
This class encapsulates the connection information of a TaskManager.
|
Class and Description |
---|
TaskManagerLocation
This class encapsulates the connection information of a TaskManager.
|
Class and Description |
---|
CheckpointResponder
Responder for checkpoint acknowledge and decline messages in the
Task . |
Class and Description |
---|
CheckpointResponder
Responder for checkpoint acknowledge and decline messages in the
Task . |
Task
The Task represents one execution of a parallel subtask on a TaskManager.
|
TaskManagerActions
Interface for the communication of the
Task with the TaskExecutor . |
TaskManagerRuntimeInfo
Interface to access
TaskExecutor information. |
UnresolvedTaskManagerLocation
This class encapsulates the connection information of a TaskManager, without resolving the
hostname.
|
Class and Description |
---|
CheckpointResponder
Responder for checkpoint acknowledge and decline messages in the
Task . |
Class and Description |
---|
CheckpointResponder
Responder for checkpoint acknowledge and decline messages in the
Task . |
NettyShuffleEnvironmentConfiguration
Configuration object for the network stack.
|
Task
The Task represents one execution of a parallel subtask on a TaskManager.
|
Task.NotifyCheckpointOperation
Various operation of notify checkpoint.
|
TaskActions
Actions which can be performed on a
Task . |
TaskExecutionState
This class represents an update about a task's execution state.
|
TaskManagerActions
Interface for the communication of the
Task with the TaskExecutor . |
TaskManagerLocation
This class encapsulates the connection information of a TaskManager.
|
TaskManagerLocation.HostNameSupplier |
TaskManagerLocation.ResolutionMode
The DNS resolution mode for TaskManager's IP address.
|
TaskManagerRuntimeInfo
Interface to access
TaskExecutor information. |
UnresolvedTaskManagerLocation
This class encapsulates the connection information of a TaskManager, without resolving the
hostname.
|
Class and Description |
---|
TaskManagerRuntimeInfo
Interface to access
TaskExecutor information. |
Class and Description |
---|
AsyncExceptionHandler
An interface marking a task as capable of handling exceptions thrown by different threads, other
than the one executing the task itself.
|
Class and Description |
---|
TaskManagerRuntimeInfo
Interface to access
TaskExecutor information. |
Class and Description |
---|
AsyncExceptionHandler
An interface marking a task as capable of handling exceptions thrown by different threads, other
than the one executing the task itself.
|
AsynchronousException
An exception for wrapping exceptions that are thrown by an operator in threads other than the
main compute thread of that operator.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.