public class DispatcherRestEndpoint extends RestServerEndpoint
Dispatcher
component.log, MAX_REQUEST_SIZE_BYTES
Constructor and Description |
---|
DispatcherRestEndpoint(RestServerEndpointConfiguration endpointConfiguration,
GatewayRetriever<DispatcherGateway> leaderRetriever,
Configuration clusterConfiguration,
RestHandlerConfiguration restConfiguration,
Executor executor) |
Modifier and Type | Method and Description |
---|---|
protected Collection<Tuple2<RestHandlerSpecification,org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler>> |
initializeHandlers(CompletableFuture<String> restAddressFuture)
This method is called at the beginning of
RestServerEndpoint.start() to setup all handlers that the REST server endpoint
implementation requires. |
void |
shutdown(Time timeout)
Stops this REST server endpoint.
|
getRestAddress, getServerAddress, start
public DispatcherRestEndpoint(RestServerEndpointConfiguration endpointConfiguration, GatewayRetriever<DispatcherGateway> leaderRetriever, Configuration clusterConfiguration, RestHandlerConfiguration restConfiguration, Executor executor)
protected Collection<Tuple2<RestHandlerSpecification,org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler>> initializeHandlers(CompletableFuture<String> restAddressFuture)
RestServerEndpoint
RestServerEndpoint.start()
to setup all handlers that the REST server endpoint
implementation requires.initializeHandlers
in class RestServerEndpoint
restAddressFuture
- future rest address of the RestServerEndpointpublic void shutdown(Time timeout)
RestServerEndpoint
shutdown
in class RestServerEndpoint
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.