Package | Description |
---|---|
org.apache.flink.mesos.runtime.clusterframework | |
org.apache.flink.runtime.clusterframework |
This package contains the cluster resource management functionality.
|
org.apache.flink.runtime.highavailability | |
org.apache.flink.runtime.highavailability.nonha | |
org.apache.flink.runtime.highavailability.zookeeper | |
org.apache.flink.runtime.jobmanager | |
org.apache.flink.runtime.jobmaster | |
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.util | |
org.apache.flink.yarn | |
org.apache.flink.yarn.highavailability |
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 |
---|
JobManager
The job manager is responsible for receiving Flink jobs, scheduling the tasks, gathering the
job status and managing the task managers.
|
SubmittedJobGraphStore
SubmittedJobGraph instances for recovery. |
SubmittedJobGraphStore.SubmittedJobGraphListener
A listener for
SubmittedJobGraph instances. |
Class and Description |
---|
SubmittedJobGraphStore
SubmittedJobGraph instances for recovery. |
Class and Description |
---|
SubmittedJobGraphStore
SubmittedJobGraph instances for recovery. |
Class and Description |
---|
SubmittedJobGraphStore
SubmittedJobGraph instances for recovery. |
Class and Description |
---|
HighAvailabilityMode
High availability mode for Flink's cluster execution.
|
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.
|
SubmittedJobGraph |
SubmittedJobGraphStore
SubmittedJobGraph instances for recovery. |
SubmittedJobGraphStore.SubmittedJobGraphListener
A listener for
SubmittedJobGraph instances. |
Class and Description |
---|
OnCompletionActions |
Class and Description |
---|
SubmittedJobGraph |
Class and Description |
---|
HighAvailabilityMode
High availability mode for Flink's cluster execution.
|
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. |
Class and Description |
---|
HighAvailabilityMode
High availability mode for Flink's cluster execution.
|
ZooKeeperSubmittedJobGraphStore
SubmittedJobGraph instances for JobManagers running in HighAvailabilityMode.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.
|
OnCompletionActions |
SubmittedJobGraphStore
SubmittedJobGraph instances for recovery. |
SubmittedJobGraphStore.SubmittedJobGraphListener
A listener for
SubmittedJobGraph instances. |
Class and Description |
---|
SubmittedJobGraphStore
SubmittedJobGraph instances for recovery. |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.