Uses of Interface
org.apache.flink.runtime.highavailability.JobResultStore

Packages that use JobResultStore

Package	Description
org.apache.flink.client.deployment.application
org.apache.flink.runtime.dispatcher
org.apache.flink.runtime.dispatcher.runner
org.apache.flink.runtime.highavailability
org.apache.flink.runtime.highavailability.nonha
org.apache.flink.runtime.highavailability.nonha.embedded
org.apache.flink.runtime.jobmanager
org.apache.flink.runtime.jobmaster

Uses of JobResultStore in org.apache.flink.client.deployment.application

Methods in org.apache.flink.client.deployment.application with parameters of type JobResultStore

Modifier and Type	Method	Description
AbstractDispatcherLeaderProcess.DispatcherGatewayService	ApplicationDispatcherGatewayServiceFactory.create(DispatcherId fencingToken, Collection<ExecutionPlan> recoveredJobs, Collection<JobResult> recoveredDirtyJobResults, ExecutionPlanWriter executionPlanWriter, JobResultStore jobResultStore)

Uses of JobResultStore in org.apache.flink.runtime.dispatcher

Methods in org.apache.flink.runtime.dispatcher that return JobResultStore

Modifier and Type	Method	Description
JobResultStore	DispatcherServices.getJobResultStore()
JobResultStore	PartialDispatcherServicesWithJobPersistenceComponents.getJobResultStore()

Methods in org.apache.flink.runtime.dispatcher with parameters of type JobResultStore

Modifier and Type	Method	Description
static PartialDispatcherServicesWithJobPersistenceComponents	PartialDispatcherServicesWithJobPersistenceComponents.from(PartialDispatcherServices partialDispatcherServices, ExecutionPlanWriter executionPlanWriter, JobResultStore jobResultStore)

Uses of JobResultStore in org.apache.flink.runtime.dispatcher.runner

Methods in org.apache.flink.runtime.dispatcher.runner with parameters of type JobResultStore

Modifier and Type	Method	Description
AbstractDispatcherLeaderProcess.DispatcherGatewayService	AbstractDispatcherLeaderProcess.DispatcherGatewayServiceFactory.create(DispatcherId dispatcherId, Collection<ExecutionPlan> recoveredJobs, Collection<JobResult> recoveredDirtyJobResults, ExecutionPlanWriter executionPlanWriter, JobResultStore jobResultStore)
static SessionDispatcherLeaderProcess	SessionDispatcherLeaderProcess.create(UUID leaderSessionId, AbstractDispatcherLeaderProcess.DispatcherGatewayServiceFactory dispatcherFactory, ExecutionPlanStore executionPlanStore, JobResultStore jobResultStore, Executor ioExecutor, FatalErrorHandler fatalErrorHandler)

Uses of JobResultStore in org.apache.flink.runtime.highavailability

Classes in org.apache.flink.runtime.highavailability that implement JobResultStore

Modifier and Type	Class	Description
class	AbstractThreadsafeJobResultStore	An abstract class for threadsafe implementations of the JobResultStore.
class	FileSystemJobResultStore	An implementation of the JobResultStore which persists job result data to an underlying distributed filesystem.

Methods in org.apache.flink.runtime.highavailability that return JobResultStore

Modifier and Type	Method	Description
JobResultStore	AbstractHaServices.getJobResultStore()
JobResultStore	HighAvailabilityServices.getJobResultStore()	Gets the store that holds information about the state of finished jobs.

Constructors in org.apache.flink.runtime.highavailability with parameters of type JobResultStore

Constructor	Description
AbstractHaServices(Configuration config, LeaderElectionDriverFactory driverFactory, Executor ioExecutor, BlobStoreService blobStoreService, JobResultStore jobResultStore)

Uses of JobResultStore in org.apache.flink.runtime.highavailability.nonha

Methods in org.apache.flink.runtime.highavailability.nonha that return JobResultStore

Modifier and Type	Method	Description
JobResultStore	AbstractNonHaServices.getJobResultStore()

Uses of JobResultStore in org.apache.flink.runtime.highavailability.nonha.embedded

Classes in org.apache.flink.runtime.highavailability.nonha.embedded that implement JobResultStore

Modifier and Type	Class	Description
class	EmbeddedJobResultStore	A thread-safe in-memory implementation of the JobResultStore.

Uses of JobResultStore in org.apache.flink.runtime.jobmanager

Methods in org.apache.flink.runtime.jobmanager that return JobResultStore

Modifier and Type	Method	Description
JobResultStore	HaServicesJobPersistenceComponentFactory.createJobResultStore()
JobResultStore	JobPersistenceComponentFactory.createJobResultStore()	Creates JobResultStore instances.

Uses of JobResultStore in org.apache.flink.runtime.jobmaster

Constructors in org.apache.flink.runtime.jobmaster with parameters of type JobResultStore

Constructor	Description
JobMasterServiceLeadershipRunner(JobMasterServiceProcessFactory jobMasterServiceProcessFactory, LeaderElection leaderElection, JobResultStore jobResultStore, LibraryCacheManager.ClassLoaderLease classLoaderLease, FatalErrorHandler fatalErrorHandler)