Uses of Interface
org.apache.flink.runtime.jobmaster.JobManagerRunner

Packages that use JobManagerRunner

Package	Description
org.apache.flink.runtime.dispatcher
org.apache.flink.runtime.dispatcher.cleanup
org.apache.flink.runtime.jobmaster

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

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

Modifier and Type	Method and Description
JobManagerRunner	JobMasterServiceLeadershipRunnerFactory.createJobManagerRunner(JobGraph jobGraph, Configuration configuration, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, JobManagerSharedServices jobManagerServices, JobManagerJobMetricGroupFactory jobManagerJobMetricGroupFactory, FatalErrorHandler fatalErrorHandler, Collection<FailureEnricher> failureEnrichers, long initializationTimestamp)
JobManagerRunner	JobManagerRunnerFactory.createJobManagerRunner(JobGraph jobGraph, Configuration configuration, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, JobManagerSharedServices jobManagerServices, JobManagerJobMetricGroupFactory jobManagerJobMetricGroupFactory, FatalErrorHandler fatalErrorHandler, Collection<FailureEnricher> failureEnrichers, long initializationTimestamp)
JobManagerRunner	OnMainThreadJobManagerRunnerRegistry.get(JobID jobId)
JobManagerRunner	JobManagerRunnerRegistry.get(JobID jobId) Returns the JobManagerRunner for the given JobID.
JobManagerRunner	DefaultJobManagerRunnerRegistry.get(JobID jobId)
JobManagerRunner	OnMainThreadJobManagerRunnerRegistry.unregister(JobID jobId)
JobManagerRunner	JobManagerRunnerRegistry.unregister(JobID jobId) Unregistered the JobManagerRunner with the given JobID.
JobManagerRunner	DefaultJobManagerRunnerRegistry.unregister(JobID jobId)

Methods in org.apache.flink.runtime.dispatcher that return types with arguments of type JobManagerRunner

Modifier and Type	Method and Description
Collection<JobManagerRunner>	OnMainThreadJobManagerRunnerRegistry.getJobManagerRunners()
Collection<JobManagerRunner>	JobManagerRunnerRegistry.getJobManagerRunners() Returns the registered JobManagerRunner instances.
Collection<JobManagerRunner>	DefaultJobManagerRunnerRegistry.getJobManagerRunners()

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

Modifier and Type	Method and Description
void	OnMainThreadJobManagerRunnerRegistry.register(JobManagerRunner jobManagerRunner)
void	JobManagerRunnerRegistry.register(JobManagerRunner jobManagerRunner) Registers the given JobManagerRunner instance.
void	DefaultJobManagerRunnerRegistry.register(JobManagerRunner jobManagerRunner)

Uses of JobManagerRunner in org.apache.flink.runtime.dispatcher.cleanup

Classes in org.apache.flink.runtime.dispatcher.cleanup that implement JobManagerRunner

Modifier and Type	Class and Description
class	CheckpointResourcesCleanupRunner CheckpointResourcesCleanupRunner implements JobManagerRunner in a way, that only the checkpoint-related resources are instantiated.

Methods in org.apache.flink.runtime.dispatcher.cleanup that return JobManagerRunner

Modifier and Type	Method and Description
JobManagerRunner	CleanupRunnerFactory.create(JobResult jobResult, CheckpointRecoveryFactory checkpointRecoveryFactory, Configuration configuration, Executor cleanupExecutor)

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

Classes in org.apache.flink.runtime.jobmaster that implement JobManagerRunner

Modifier and Type	Class and Description
class	JobMasterServiceLeadershipRunner Leadership runner for the JobMasterServiceProcess.