Class and Description |
---|
Task
The Task represents one execution of a parallel subtask on a TaskManager.
|
TaskManager
The TaskManager is responsible for executing the individual tasks of a Flink job.
|
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 |
---|
TaskManagerRuntimeInfo
Interface to access
TaskManager 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 |
---|
Task
The Task represents one execution of a parallel subtask on a TaskManager.
|
TaskManagerLocation
This class encapsulates the connection information of a TaskManager.
|
Class and Description |
---|
TaskActions
Actions which can be performed on a
Task . |
Class and Description |
---|
TaskActions
Actions which can be performed on a
Task . |
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 |
---|
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 |
---|
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 |
---|
Task
The Task represents one execution of a parallel subtask on a TaskManager.
|
Class and Description |
---|
TaskManager
The TaskManager is responsible for executing the individual tasks of a Flink job.
|
TaskManagerLocation
This class encapsulates the connection information of a TaskManager.
|
Class and Description |
---|
TaskManagerRuntimeInfo
Interface to access
TaskManager information. |
Class and Description |
---|
CheckpointResponder
Responder for checkpoint acknowledge and decline messages in the
Task . |
NetworkEnvironmentConfiguration
Configuration object for the network stack.
|
TaskManagerActions
Interface for the communication of the
Task with the TaskManager . |
TaskManagerLocation
This class encapsulates the connection information of a TaskManager.
|
TaskManagerRuntimeInfo
Interface to access
TaskManager information. |
Class and Description |
---|
CheckpointResponder
Responder for checkpoint acknowledge and decline messages in the
Task . |
TaskActions
Actions which can be performed on a
Task . |
Class and Description |
---|
Task
The Task represents one execution of a parallel subtask on a TaskManager.
|
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.
|
TaskActions
Actions which can be performed on a
Task . |
TaskExecutionState
This class represents an update about a task's execution state.
|
TaskExecutionStateListener |
TaskManager
The TaskManager is responsible for executing the individual tasks of a Flink job.
|
TaskManager$
TaskManager companion object.
|
TaskManagerActions
Interface for the communication of the
Task with the TaskManager . |
TaskManagerLocation
This class encapsulates the connection information of a TaskManager.
|
TaskManagerRuntimeInfo
Interface to access
TaskManager information. |
Class and Description |
---|
Task
The Task represents one execution of a parallel subtask on a TaskManager.
|
TaskManager
The TaskManager is responsible for executing the individual tasks of a Flink job.
|
TaskManagerLocation
This class encapsulates the connection information of a TaskManager.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.