Class and Description |
---|
JobGraphStoreFactory
Factory for
JobGraphStore . |
JobGraphWriter
Allows to store and remove job graphs.
|
Class and Description |
---|
JobGraphStore
JobGraph instances for recovery. |
JobGraphStoreUtil
JobGraphStore utility interfaces.
|
Class and Description |
---|
JobGraphStore
JobGraph instances for recovery. |
Class and Description |
---|
JobGraphStore
JobGraph instances for recovery. |
JobGraphStore.JobGraphListener
A listener for
JobGraph instances. |
JobGraphWriter
Allows to store and remove job graphs.
|
Class and Description |
---|
JobGraphStore
JobGraph instances for recovery. |
JobGraphStore.JobGraphListener
A listener for
JobGraph instances. |
JobGraphStoreFactory
Factory for
JobGraphStore . |
JobGraphWriter
Allows to store and remove job graphs.
|
Class and Description |
---|
JobGraphStore
JobGraph instances for recovery. |
Class and Description |
---|
JobGraphStore
JobGraph instances for recovery. |
Class and Description |
---|
JobGraphStore
JobGraph instances for recovery. |
Class and Description |
---|
HighAvailabilityMode
High availability mode for Flink's cluster execution.
|
JobGraphStore
JobGraph instances for recovery. |
JobGraphStore.JobGraphListener
A listener for
JobGraph instances. |
JobGraphStoreFactory
Factory for
JobGraphStore . |
JobGraphStoreUtil
JobGraphStore utility interfaces.
|
JobGraphStoreWatcher
A watcher on
JobGraphStore . |
JobGraphWriter
Allows to store and remove job graphs.
|
JobManagerProcessSpec
Describe the specifics of different resource dimensions of the JobManager process.
|
NoOpJobGraphStoreWatcher
Singleton
JobGraphStoreWatcher empty implementation. |
ThrowingJobGraphWriter
JobGraphWriter implementation which does not allow to store JobGraph . |
ZooKeeperJobGraphStoreUtil
Singleton
JobGraphStoreUtil implementation for ZooKeeper. |
Class and Description |
---|
OnCompletionActions
Interface for completion actions once a Flink job has reached a terminal state.
|
Class and Description |
---|
OnCompletionActions
Interface for completion actions once a Flink job has reached a terminal state.
|
Class and Description |
---|
PartitionProducerDisposedException
Exception returned to a TaskManager on JobMaster requesting partition state, if the producer of a
partition has been disposed.
|
Class and Description |
---|
PartitionProducerDisposedException
Exception returned to a TaskManager on JobMaster requesting partition state, if the producer of a
partition has been disposed.
|
Class and Description |
---|
JobGraphStore
JobGraph instances for recovery. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.