Class | Description |
---|---|
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 | |
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$ | |
TaskManagerRuntimeInfo |
Encapsulation of TaskManager runtime information, like hostname and configuration.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.