Package org.apache.flink.runtime.highavailability
-
Interface Summary Interface Description ClientHighAvailabilityServices ClientHighAvailabilityServices
provides services those are required on client-side.ClientHighAvailabilityServicesFactory Factory interface forClientHighAvailabilityServices
.HighAvailabilityServices The HighAvailabilityServices give access to all services needed for a highly-available setup.HighAvailabilityServicesFactory Factory interface forHighAvailabilityServices
.JobResultStore A storage for the results of globally terminated jobs. -
Class Summary Class Description AbstractHaServices Abstract high availability services based on distributed system(e.g.AbstractThreadsafeJobResultStore An abstract class for threadsafe implementations of theJobResultStore
.DefaultClientHighAvailabilityServicesFactory Default factory for creating client high availability services.FileSystemJobResultStore An implementation of theJobResultStore
which persists job result data to an underlying distributed filesystem.HighAvailabilityServicesUtils Utils class to instantiateHighAvailabilityServices
implementations.JobResultEntry JobResultEntry
is the entity managed by theJobResultStore
.JobResultStoreOptions The set of configuration options relating to the Job Result Store.