Package | Description |
---|---|
org.apache.flink.mesos.runtime.clusterframework | |
org.apache.flink.runtime.deployment | |
org.apache.flink.runtime.execution | |
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.instance | |
org.apache.flink.runtime.io.network | |
org.apache.flink.runtime.io.network.partition | |
org.apache.flink.runtime.io.network.partition.consumer | |
org.apache.flink.runtime.jobmanager.scheduler | |
org.apache.flink.runtime.jobmanager.slots | |
org.apache.flink.runtime.messages |
This package contains the messages that are sent between actors, like the
JobManager and
TaskManager to coordinate the distributed operations. |
org.apache.flink.runtime.metrics.groups | |
org.apache.flink.runtime.minicluster | |
org.apache.flink.runtime.operators | |
org.apache.flink.runtime.taskmanager | |
org.apache.flink.yarn |
Class and Description |
---|
TaskManager
The TaskManager is responsible for executing the individual tasks of a Flink job.
|
TaskManagerConfiguration |
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
Encapsulation of TaskManager runtime information, like hostname and configuration.
|
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 |
---|
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.
|
TaskManagerConfiguration |
TaskManagerLocation
This class encapsulates the connection information of a TaskManager.
|
Class and Description |
---|
TaskManagerRuntimeInfo
Encapsulation of TaskManager runtime information, like hostname and configuration.
|
Class and Description |
---|
CheckpointResponder
Responder for checkpoint acknowledge and decline messages in the
Task . |
NetworkEnvironmentConfiguration |
NetworkEnvironmentConfiguration$ |
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.
|
TaskManagerConfiguration |
TaskManagerConfiguration$ |
TaskManagerConnection
Interface for the communication of the
Task with the TaskManager . |
TaskManagerLocation
This class encapsulates the connection information of a TaskManager.
|
TaskManagerRuntimeInfo
Encapsulation of TaskManager runtime information, like hostname and configuration.
|
Class and Description |
---|
TaskManager
The TaskManager is responsible for executing the individual tasks of a Flink job.
|
TaskManagerConfiguration |
TaskManagerLocation
This class encapsulates the connection information of a TaskManager.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.