org.apache.flink.runtime.dispatcher.runner

Interface AbstractDispatcherLeaderProcess.DispatcherGatewayServiceFactory

All Known Implementing Classes:

ApplicationDispatcherGatewayServiceFactory

Enclosing class:

AbstractDispatcherLeaderProcess

public static interface AbstractDispatcherLeaderProcess.DispatcherGatewayServiceFactory

Factory for AbstractDispatcherLeaderProcess.DispatcherGatewayService.

Method Summary

Modifier and Type	Method and Description
AbstractDispatcherLeaderProcess.DispatcherGatewayService	create(DispatcherId dispatcherId, Collection<JobGraph> recoveredJobs, Collection<JobResult> recoveredDirtyJobResults, JobGraphWriter jobGraphWriter, JobResultStore jobResultStore)

Method Detail

create

AbstractDispatcherLeaderProcess.DispatcherGatewayService create(DispatcherId dispatcherId,
                                                                Collection<JobGraph> recoveredJobs,
                                                                Collection<JobResult> recoveredDirtyJobResults,
                                                                JobGraphWriter jobGraphWriter,
                                                                JobResultStore jobResultStore)