Modifier and Type | Method and Description |
---|---|
static <R extends RequestBody,M extends MessageParameters> |
HandlerRequest.create(R requestBody,
M messageParameters)
Short-cut for
create(RequestBody, MessageParameters, Collection) without any
uploaded files. |
static <R extends RequestBody,M extends MessageParameters> |
HandlerRequest.create(R requestBody,
M messageParameters,
Collection<File> uploadedFiles)
Creates a new
HandlerRequest . |
static <R extends RequestBody,M extends MessageParameters> |
HandlerRequest.resolveParametersAndCreate(R requestBody,
M messageParameters,
Map<String,String> receivedPathParameters,
Map<String,List<String>> receivedQueryParameters,
Collection<File> uploadedFiles)
Creates a new
HandlerRequest after resolving the given MessageParameters
against the given query/path parameter maps. |
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 CompletableFuture<Void> |
AbstractRestHandler.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) |
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 |
---|---|
protected abstract K |
AbstractAsynchronousOperationHandlers.TriggerHandler.createOperationKey(HandlerRequest<B> request)
Create the operation key under which the result future of the asynchronous operation will
be stored.
|
protected abstract K |
AbstractAsynchronousOperationHandlers.StatusHandler.getOperationKey(HandlerRequest<EmptyRequestBody> request)
Extract the operation key under which the operation result future is stored.
|
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 OperationKey |
ClusterDataSetDeleteHandlers.ClusterDataSetDeleteTriggerHandler.createOperationKey(HandlerRequest<EmptyRequestBody> request) |
protected OperationKey |
ClusterDataSetDeleteHandlers.ClusterDataSetDeleteStatusHandler.getOperationKey(HandlerRequest<EmptyRequestBody> request) |
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 AsynchronousJobOperationKey |
RescalingHandlers.RescalingTriggerHandler.createOperationKey(HandlerRequest<EmptyRequestBody> request) |
protected AsynchronousJobOperationKey |
RescalingHandlers.RescalingStatusHandler.getOperationKey(HandlerRequest<EmptyRequestBody> request) |
CompletableFuture<TriggerResponse> |
RescalingHandlers.RescalingTriggerHandler.handleRequest(HandlerRequest<EmptyRequestBody> request,
RestfulGateway gateway) |
CompletableFuture<AsynchronousOperationResult<AsynchronousOperationInfo>> |
RescalingHandlers.RescalingStatusHandler.handleRequest(HandlerRequest<EmptyRequestBody> request,
RestfulGateway gateway) |
protected CompletableFuture<Acknowledge> |
RescalingHandlers.RescalingTriggerHandler.triggerOperation(HandlerRequest<EmptyRequestBody> request,
RestfulGateway gateway) |
Modifier and Type | Method and Description |
---|---|
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 String |
TaskManagerCustomLogHandler.getFileName(HandlerRequest<EmptyRequestBody> handlerRequest) |
protected String |
AbstractTaskManagerFileHandler.getFileName(HandlerRequest<EmptyRequestBody> handlerRequest) |
protected CompletableFuture<TaskManagersInfo> |
TaskManagersHandler.handleRequest(HandlerRequest<EmptyRequestBody> request,
ResourceManagerGateway gateway) |
protected CompletableFuture<TaskManagerDetailsInfo> |
TaskManagerDetailsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request,
ResourceManagerGateway gateway) |
protected CompletableFuture<LogListInfo> |
TaskManagerLogListHandler.handleRequest(HandlerRequest<EmptyRequestBody> request,
ResourceManagerGateway gateway) |
protected CompletableFuture<ThreadDumpInfo> |
TaskManagerThreadDumpHandler.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 <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 |
---|---|
CompletableFuture<JarUploadResponseBody> |
JarUploadHandler.handleRequest(HandlerRequest<EmptyRequestBody> request,
RestfulGateway gateway) |
protected CompletableFuture<JarListInfo> |
JarListHandler.handleRequest(HandlerRequest<EmptyRequestBody> request,
RestfulGateway gateway) |
protected CompletableFuture<EmptyResponseBody> |
JarDeleteHandler.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. |
protected CompletableFuture<Void> |
AbstractSqlGatewayRestHandler.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,
NonLeaderRetrievalRestfulGateway gateway) |
Modifier and Type | Method and Description |
---|---|
protected CompletableFuture<OperationStatusResponseBody> |
AbstractOperationHandler.handleRequest(SqlGatewayRestAPIVersion version,
HandlerRequest<EmptyRequestBody> request) |
Modifier and Type | Method and Description |
---|---|
protected CompletableFuture<GetSessionConfigResponseBody> |
GetSessionConfigHandler.handleRequest(SqlGatewayRestAPIVersion version,
HandlerRequest<EmptyRequestBody> request) |
protected CompletableFuture<EmptyResponseBody> |
TriggerSessionHeartbeatHandler.handleRequest(SqlGatewayRestAPIVersion version,
HandlerRequest<EmptyRequestBody> request) |
protected CompletableFuture<CloseSessionResponseBody> |
CloseSessionHandler.handleRequest(SqlGatewayRestAPIVersion version,
HandlerRequest<EmptyRequestBody> request) |
protected CompletableFuture<OpenSessionResponseBody> |
OpenSessionHandler.handleRequest(SqlGatewayRestAPIVersion version,
HandlerRequest<OpenSessionRequestBody> request) |
Modifier and Type | Method and Description |
---|---|
protected CompletableFuture<FetchResultsResponseBody> |
FetchResultsHandler.handleRequest(SqlGatewayRestAPIVersion version,
HandlerRequest<EmptyRequestBody> request) |
protected CompletableFuture<ExecuteStatementResponseBody> |
ExecuteStatementHandler.handleRequest(SqlGatewayRestAPIVersion version,
HandlerRequest<ExecuteStatementRequestBody> request) |
Modifier and Type | Method and Description |
---|---|
protected CompletableFuture<GetInfoResponseBody> |
GetInfoHandler.handleRequest(SqlGatewayRestAPIVersion version,
HandlerRequest<EmptyRequestBody> request) |
protected CompletableFuture<GetApiVersionResponseBody> |
GetApiVersionHandler.handleRequest(SqlGatewayRestAPIVersion version,
HandlerRequest<EmptyRequestBody> request) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.