Package | Description |
---|---|
org.apache.flink.runtime.execution | |
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.io.network | |
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.operators | |
org.apache.flink.runtime.taskmanager | |
org.apache.flink.yarn |
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.
|
Class and Description |
---|
NetworkEnvironmentConfiguration |
Task
The Task represents one execution of a parallel subtask on a TaskManager.
|
Class and Description |
---|
TaskExecutionState
This class represents an update about a task's execution state.
|
Class and Description |
---|
TaskManagerRuntimeInfo
Encapsulation of TaskManager runtime information, like hostname and configuration.
|
Class and Description |
---|
NetworkEnvironmentConfiguration |
NetworkEnvironmentConfiguration$ |
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.
|
TaskManager$
TaskManager companion object.
|
TaskManagerConfiguration |
TaskManagerConfiguration$ |
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 |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.