org.apache.flink.runtime.rest

Interface RestEndpointFactory<T extends RestfulGateway>

Type Parameters:

T - type of the RestfulGateway

All Known Implementing Classes:

JobRestEndpointFactory, SessionRestEndpointFactory

public interface RestEndpointFactory<T extends RestfulGateway>

WebMonitorEndpoint factory.

Method Summary

Modifier and Type	Method and Description
static ExecutionGraphCache	createExecutionGraphCache(RestHandlerConfiguration restConfiguration)
WebMonitorEndpoint<T>	createRestEndpoint(Configuration configuration, LeaderGatewayRetriever<DispatcherGateway> dispatcherGatewayRetriever, LeaderGatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, TransientBlobService transientBlobService, ScheduledExecutorService executor, MetricFetcher metricFetcher, LeaderElectionService leaderElectionService, FatalErrorHandler fatalErrorHandler)

Method Detail

createRestEndpoint

WebMonitorEndpoint<T> createRestEndpoint(Configuration configuration,
                                         LeaderGatewayRetriever<DispatcherGateway> dispatcherGatewayRetriever,
                                         LeaderGatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever,
                                         TransientBlobService transientBlobService,
                                         ScheduledExecutorService executor,
                                         MetricFetcher metricFetcher,
                                         LeaderElectionService leaderElectionService,
                                         FatalErrorHandler fatalErrorHandler)
                                  throws Exception

Throws:

Exception

createExecutionGraphCache

static ExecutionGraphCache createExecutionGraphCache(RestHandlerConfiguration restConfiguration)