Interface | Description |
---|---|
SubmittedJobGraphStore |
SubmittedJobGraph instances for recovery. |
SubmittedJobGraphStore.SubmittedJobGraphListener |
A listener for
SubmittedJobGraph instances. |
Class | Description |
---|---|
JobInfo |
Utility class to store job information on the
JobManager . |
JobInfo$ | |
JobManager |
The job manager is responsible for receiving Flink jobs, scheduling the tasks, gathering the
job status and managing the task managers.
|
JobManager$ |
Job Manager companion object.
|
JobManagerCliOptions |
The command line parameters passed to the TaskManager.
|
MemoryArchivist |
Actor which stores terminated Flink jobs.
|
StandaloneSubmittedJobGraphStore |
SubmittedJobGraph instances for JobManagers running in RecoveryMode.STANDALONE . |
SubmittedJobGraph | |
ZooKeeperSubmittedJobGraphStore |
SubmittedJobGraph instances for JobManagers running in RecoveryMode.ZOOKEEPER . |
Enum | Description |
---|---|
JobManagerMode |
The startup mode for the JobManager.
|
RecoveryMode |
Recovery mode for Flink's cluster execution.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.