Class and Description |
---|
SubmittedJobGraph
A recoverable
JobGraph and JobInfo . |
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.
|
JobManagerMode
The startup mode for the JobManager.
|
SubmittedJobGraph
A recoverable
JobGraph and JobInfo . |
SubmittedJobGraphStore
SubmittedJobGraph instances for recovery. |
SubmittedJobGraphStore.SubmittedJobGraphListener
A listener for
SubmittedJobGraph instances. |
Class and Description |
---|
OnCompletionActions
Interface for completion actions once a Flink job has reached
a terminal state.
|
Class and Description |
---|
HighAvailabilityMode
High availability mode for Flink's cluster execution.
|
ZooKeeperSubmittedJobGraphStore
SubmittedJobGraph instances for JobManagers running in HighAvailabilityMode.ZOOKEEPER . |
Class and Description |
---|
SubmittedJobGraphStore
SubmittedJobGraph instances for recovery. |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.