Package org.apache.flink.runtime.dispatcher

Class PartialDispatcherServicesWithJobPersistenceComponents

java.lang.Object

org.apache.flink.runtime.dispatcher.PartialDispatcherServices

org.apache.flink.runtime.dispatcher.PartialDispatcherServicesWithJobPersistenceComponents

public class PartialDispatcherServicesWithJobPersistenceComponents
extends PartialDispatcherServices

DispatcherFactory services container.

Method Summary

Modifier and Type	Method	Description
static PartialDispatcherServicesWithJobPersistenceComponents	from(PartialDispatcherServices partialDispatcherServices, JobGraphWriter jobGraphWriter, JobResultStore jobResultStore)
JobGraphWriter	getJobGraphWriter()
JobResultStore	getJobResultStore()

Methods inherited from class org.apache.flink.runtime.dispatcher.PartialDispatcherServices

getArchivedExecutionGraphStore, getBlobServer, getConfiguration, getFailureEnrichers, getFatalErrorHandler, getHeartbeatServices, getHighAvailabilityServices, getHistoryServerArchivist, getIoExecutor, getJobManagerMetricGroupFactory, getMetricQueryServiceAddress, getOperationCaches, getResourceManagerGatewayRetriever

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getJobGraphWriter

public JobGraphWriter getJobGraphWriter()

getJobResultStore

public JobResultStore getJobResultStore()

from

public static PartialDispatcherServicesWithJobPersistenceComponents from(PartialDispatcherServices partialDispatcherServices,
                                                                         JobGraphWriter jobGraphWriter,
                                                                         JobResultStore jobResultStore)