Package 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	Description
AbstractDispatcherLeaderProcess.DispatcherGatewayService	create(DispatcherId dispatcherId, Collection<ExecutionPlan> recoveredJobs, Collection<JobResult> recoveredDirtyJobResults, ExecutionPlanWriter executionPlanWriter, JobResultStore jobResultStore)

Method Detail

create

AbstractDispatcherLeaderProcess.DispatcherGatewayService create(DispatcherId dispatcherId,
                                                                Collection<ExecutionPlan> recoveredJobs,
                                                                Collection<JobResult> recoveredDirtyJobResults,
                                                                ExecutionPlanWriter executionPlanWriter,
                                                                JobResultStore jobResultStore)