Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.jobmanager | |
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.minicluster | |
org.apache.flink.runtime.testingUtils | |
org.apache.flink.runtime.util | |
org.apache.flink.yarn |
Class and Description |
---|
RecoveryMode
Recovery mode for Flink's cluster execution.
|
Class and Description |
---|
RecoveryMode
Recovery mode for Flink's cluster execution.
|
Class and 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.
|
JobManagerMode
The startup mode for the JobManager.
|
MemoryArchivist
Actor which stores terminated Flink jobs.
|
RecoveryMode
Recovery mode for Flink's cluster execution.
|
SubmittedJobGraph |
SubmittedJobGraphStore
SubmittedJobGraph instances for recovery. |
SubmittedJobGraphStore.SubmittedJobGraphListener
A listener for
SubmittedJobGraph instances. |
Class and Description |
---|
SubmittedJobGraph |
Class and Description |
---|
RecoveryMode
Recovery mode for Flink's cluster execution.
|
Class and Description |
---|
JobManager
The job manager is responsible for receiving Flink jobs, scheduling the tasks, gathering the
job status and managing the task managers.
|
MemoryArchivist
Actor which stores terminated Flink jobs.
|
SubmittedJobGraphStore
SubmittedJobGraph instances for recovery. |
SubmittedJobGraphStore.SubmittedJobGraphListener
A listener for
SubmittedJobGraph instances. |
Class and Description |
---|
RecoveryMode
Recovery mode for Flink's cluster execution.
|
ZooKeeperSubmittedJobGraphStore
SubmittedJobGraph instances for JobManagers running in RecoveryMode.ZOOKEEPER . |
Class and Description |
---|
JobManager
The job manager is responsible for receiving Flink jobs, scheduling the tasks, gathering the
job status and managing the task managers.
|
MemoryArchivist
Actor which stores terminated Flink jobs.
|
SubmittedJobGraphStore
SubmittedJobGraph instances for recovery. |
SubmittedJobGraphStore.SubmittedJobGraphListener
A listener for
SubmittedJobGraph instances. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.