public class DispatcherRestEndpoint extends WebMonitorEndpoint<DispatcherGateway>
Dispatcher
component.RestServerEndpoint.RestHandlerUrlComparator
clusterConfiguration, executor, leaderRetriever, restConfiguration
log, responseHeaders, uploadDir
Constructor and Description |
---|
DispatcherRestEndpoint(RestServerEndpointConfiguration endpointConfiguration,
GatewayRetriever<DispatcherGateway> leaderRetriever,
Configuration clusterConfiguration,
RestHandlerConfiguration restConfiguration,
GatewayRetriever<ResourceManagerGateway> resourceManagerRetriever,
TransientBlobService transientBlobService,
ScheduledExecutorService executor,
MetricFetcher metricFetcher,
LeaderElectionService leaderElectionService,
ExecutionGraphCache executionGraphCache,
FatalErrorHandler fatalErrorHandler) |
Modifier and Type | Method and Description |
---|---|
protected List<Tuple2<RestHandlerSpecification,org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler>> |
initializeHandlers(CompletableFuture<String> localAddressFuture)
This method is called at the beginning of
RestServerEndpoint.start() to setup all handlers that the
REST server endpoint implementation requires. |
protected Collection<Tuple2<RestHandlerSpecification,org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler>> |
initializeWebSubmissionHandlers(CompletableFuture<String> localAddressFuture) |
protected CompletableFuture<Void> |
shutDownInternal()
Stops this REST server endpoint.
|
archiveJsonWithPath, createExecutorService, getDescription, grantLeadership, handleError, revokeLeadership, startInternal
closeAsync, getRestBaseUrl, getServerAddress, start
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
public DispatcherRestEndpoint(RestServerEndpointConfiguration endpointConfiguration, GatewayRetriever<DispatcherGateway> leaderRetriever, Configuration clusterConfiguration, RestHandlerConfiguration restConfiguration, GatewayRetriever<ResourceManagerGateway> resourceManagerRetriever, TransientBlobService transientBlobService, ScheduledExecutorService executor, MetricFetcher metricFetcher, LeaderElectionService leaderElectionService, ExecutionGraphCache executionGraphCache, FatalErrorHandler fatalErrorHandler) throws IOException
IOException
protected List<Tuple2<RestHandlerSpecification,org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler>> initializeHandlers(CompletableFuture<String> localAddressFuture)
RestServerEndpoint
RestServerEndpoint.start()
to setup all handlers that the
REST server endpoint implementation requires.initializeHandlers
in class WebMonitorEndpoint<DispatcherGateway>
localAddressFuture
- future rest address of the RestServerEndpointprotected Collection<Tuple2<RestHandlerSpecification,org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler>> initializeWebSubmissionHandlers(CompletableFuture<String> localAddressFuture)
initializeWebSubmissionHandlers
in class WebMonitorEndpoint<DispatcherGateway>
protected CompletableFuture<Void> shutDownInternal()
RestServerEndpoint
shutDownInternal
in class WebMonitorEndpoint<DispatcherGateway>
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.