Modifier and Type | Class and Description |
---|---|
class |
NotFoundException
A special exception that indicates that an element was not found and that the request should be
answered with a
404 return code. |
Modifier and Type | Method and Description |
---|---|
protected abstract CompletableFuture<P> |
AbstractRestHandler.handleRequest(HandlerRequest<R> request,
T gateway)
This method is called for every incoming request and returns a
CompletableFuture
containing a the response. |
protected abstract CompletableFuture<Void> |
AbstractHandler.respondToRequest(org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerContext ctx,
org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpRequest httpRequest,
HandlerRequest<R> handlerRequest,
T gateway)
Respond to the given
HandlerRequest . |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<TriggerResponse> |
AbstractAsynchronousOperationHandlers.TriggerHandler.handleRequest(HandlerRequest<B> request,
T gateway) |
CompletableFuture<AsynchronousOperationResult<V>> |
AbstractAsynchronousOperationHandlers.StatusHandler.handleRequest(HandlerRequest<EmptyRequestBody> request,
T gateway) |
protected abstract CompletableFuture<R> |
AbstractAsynchronousOperationHandlers.TriggerHandler.triggerOperation(HandlerRequest<B> request,
T gateway)
Trigger the asynchronous operation and return its future result.
|
Modifier and Type | Method and Description |
---|---|
protected CompletableFuture<ConfigurationInfo> |
ClusterConfigHandler.handleRequest(HandlerRequest<EmptyRequestBody> request,
RestfulGateway gateway) |
protected CompletableFuture<LogListInfo> |
JobManagerLogListHandler.handleRequest(HandlerRequest<EmptyRequestBody> request,
RestfulGateway gateway) |
protected CompletableFuture<EnvironmentInfo> |
JobManagerEnvironmentHandler.handleRequest(HandlerRequest<EmptyRequestBody> request,
RestfulGateway gateway) |
protected CompletableFuture<EmptyResponseBody> |
ShutdownHandler.handleRequest(HandlerRequest<EmptyRequestBody> request,
RestfulGateway gateway) |
protected CompletableFuture<ThreadDumpInfo> |
JobManagerThreadDumpHandler.handleRequest(HandlerRequest<EmptyRequestBody> request,
RestfulGateway gateway) |
Modifier and Type | Method and Description |
---|---|
protected CompletableFuture<ClusterDataSetListResponseBody> |
ClusterDataSetListHandler.handleRequest(HandlerRequest<EmptyRequestBody> request,
ResourceManagerGateway gateway) |
protected CompletableFuture<ClusterDataSetDeleteHandlers.SerializableVoid> |
ClusterDataSetDeleteHandlers.ClusterDataSetDeleteTriggerHandler.triggerOperation(HandlerRequest<EmptyRequestBody> request,
RestfulGateway gateway) |
Modifier and Type | Method and Description |
---|---|
protected CompletableFuture<ClientCoordinationResponseBody> |
ClientCoordinationHandler.handleRequest(HandlerRequest<ClientCoordinationRequestBody> request,
RestfulGateway gateway) |
Modifier and Type | Method and Description |
---|---|
protected MetricCollectionResponseBody |
JobVertexWatermarksHandler.handleRequest(HandlerRequest<EmptyRequestBody> request,
AccessExecutionJobVertex jobVertex) |
protected CompletableFuture<AggregatedMetricsResponseBody> |
AbstractAggregatingMetricsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request,
RestfulGateway gateway) |
protected CompletableFuture<MetricCollectionResponseBody> |
AbstractMetricsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request,
RestfulGateway gateway) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<TriggerResponse> |
RescalingHandlers.RescalingTriggerHandler.handleRequest(HandlerRequest<EmptyRequestBody> request,
RestfulGateway gateway) |
CompletableFuture<AsynchronousOperationResult<AsynchronousOperationInfo>> |
RescalingHandlers.RescalingStatusHandler.handleRequest(HandlerRequest<EmptyRequestBody> request,
RestfulGateway gateway) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<AsynchronousOperationResult<SavepointInfo>> |
SavepointHandlers.SavepointStatusHandler.handleRequest(HandlerRequest<EmptyRequestBody> request,
RestfulGateway gateway) |
protected CompletableFuture<Acknowledge> |
SavepointDisposalHandlers.SavepointDisposalTriggerHandler.triggerOperation(HandlerRequest<SavepointDisposalRequest> request,
RestfulGateway gateway) |
protected CompletableFuture<Acknowledge> |
SavepointHandlers.SavepointTriggerHandler.triggerOperation(HandlerRequest<SavepointTriggerRequestBody> request,
AsynchronousJobOperationKey operationKey,
RestfulGateway gateway) |
protected CompletableFuture<Acknowledge> |
SavepointHandlers.StopWithSavepointHandler.triggerOperation(HandlerRequest<StopWithSavepointRequestBody> request,
AsynchronousJobOperationKey operationKey,
RestfulGateway gateway) |
Modifier and Type | Method and Description |
---|---|
static void |
StaticFileServerHandler.checkFileValidity(File file,
File rootPath,
org.slf4j.Logger logger)
Checks various conditions for file access.
|
Modifier and Type | Method and Description |
---|---|
static ResourceManagerGateway |
AbstractResourceManagerHandler.getResourceManagerGateway(GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever) |
protected abstract CompletableFuture<P> |
AbstractResourceManagerHandler.handleRequest(HandlerRequest<R> request,
ResourceManagerGateway gateway) |
protected CompletableFuture<P> |
AbstractResourceManagerHandler.handleRequest(HandlerRequest<R> request,
T gateway) |
Modifier and Type | Method and Description |
---|---|
protected CompletableFuture<ThreadDumpInfo> |
TaskManagerThreadDumpHandler.handleRequest(HandlerRequest<EmptyRequestBody> request,
ResourceManagerGateway gateway) |
protected CompletableFuture<TaskManagerDetailsInfo> |
TaskManagerDetailsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request,
ResourceManagerGateway gateway) |
protected CompletableFuture<TaskManagersInfo> |
TaskManagersHandler.handleRequest(HandlerRequest<EmptyRequestBody> request,
ResourceManagerGateway gateway) |
protected CompletableFuture<LogListInfo> |
TaskManagerLogListHandler.handleRequest(HandlerRequest<EmptyRequestBody> request,
ResourceManagerGateway gateway) |
protected CompletableFuture<Void> |
AbstractTaskManagerFileHandler.respondToRequest(org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerContext ctx,
org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpRequest httpRequest,
HandlerRequest<EmptyRequestBody> handlerRequest,
RestfulGateway gateway) |
Modifier and Type | Method and Description |
---|---|
static <T> T |
HandlerRequestUtils.fromRequestBodyOrQueryParameter(T requestValue,
SupplierWithException<T,RestHandlerException> queryParameterExtractor,
T defaultValue,
org.slf4j.Logger log)
Returns
requestValue if it is not null, otherwise returns the query parameter value
if it is not null, otherwise returns the default value. |
Modifier and Type | Method and Description |
---|---|
static <T> T |
HandlerRequestUtils.fromRequestBodyOrQueryParameter(T requestValue,
SupplierWithException<T,RestHandlerException> queryParameterExtractor,
T defaultValue,
org.slf4j.Logger log)
Returns
requestValue if it is not null, otherwise returns the query parameter value
if it is not null, otherwise returns the default value. |
static <X,P extends MessageQueryParameter<X>,R extends RequestBody,M extends MessageParameters> |
HandlerRequestUtils.getQueryParameter(HandlerRequest<R> request,
Class<P> queryParameterClass)
Returns the value of a query parameter, or
null if the query parameter is not set. |
static <X,P extends MessageQueryParameter<X>,R extends RequestBody,M extends MessageParameters> |
HandlerRequestUtils.getQueryParameter(HandlerRequest<R> request,
Class<P> queryParameterClass,
X defaultValue) |
Modifier and Type | Method and Description |
---|---|
protected CompletableFuture<JarListInfo> |
JarListHandler.handleRequest(HandlerRequest<EmptyRequestBody> request,
RestfulGateway gateway) |
protected CompletableFuture<EmptyResponseBody> |
JarDeleteHandler.handleRequest(HandlerRequest<EmptyRequestBody> request,
RestfulGateway gateway) |
CompletableFuture<JarUploadResponseBody> |
JarUploadHandler.handleRequest(HandlerRequest<EmptyRequestBody> request,
RestfulGateway gateway) |
protected CompletableFuture<JobPlanInfo> |
JarPlanHandler.handleRequest(HandlerRequest<JarPlanRequestBody> request,
RestfulGateway gateway) |
CompletableFuture<JarRunResponseBody> |
JarRunHandler.handleRequest(HandlerRequest<JarRunRequestBody> request,
DispatcherGateway gateway) |
Modifier and Type | Method and Description |
---|---|
static <R extends JarRequestBody> |
JarHandlerUtils.JarHandlerContext.fromRequest(HandlerRequest<R> request,
Path jarDir,
org.slf4j.Logger log) |
Modifier and Type | Method and Description |
---|---|
protected abstract CompletableFuture<P> |
AbstractSqlGatewayRestHandler.handleRequest(SqlGatewayRestAPIVersion version,
HandlerRequest<R> request)
This method is called for every incoming request and returns a
CompletableFuture
containing a the response. |
Modifier and Type | Method and Description |
---|---|
protected CompletableFuture<OperationStatusResponseBody> |
AbstractOperationHandler.handleRequest(SqlGatewayRestAPIVersion version,
HandlerRequest<EmptyRequestBody> request) |
Modifier and Type | Method and Description |
---|---|
protected CompletableFuture<EmptyResponseBody> |
TriggerSessionHeartbeatHandler.handleRequest(SqlGatewayRestAPIVersion version,
HandlerRequest<EmptyRequestBody> request) |
protected CompletableFuture<GetSessionConfigResponseBody> |
GetSessionConfigHandler.handleRequest(SqlGatewayRestAPIVersion version,
HandlerRequest<EmptyRequestBody> request) |
protected CompletableFuture<CloseSessionResponseBody> |
CloseSessionHandler.handleRequest(SqlGatewayRestAPIVersion version,
HandlerRequest<EmptyRequestBody> request) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.