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 . |
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 . |
JobGraphWriter
Allows to store and remove job graphs.
|
ThrowingJobGraphWriter
JobGraphWriter implementation which does not allow to store
JobGraph . |
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 |
---|
ZooKeeperJobGraphStore
JobGraph instances for JobManagers running in HighAvailabilityMode.ZOOKEEPER . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.