Uses of Class
org.apache.flink.runtime.rest.handler.RestHandlerException

Packages that use RestHandlerException

Package	Description
org.apache.flink.runtime.rest
org.apache.flink.runtime.rest.handler
org.apache.flink.runtime.rest.handler.async
org.apache.flink.runtime.rest.handler.cluster
org.apache.flink.runtime.rest.handler.dataset
org.apache.flink.runtime.rest.handler.job
org.apache.flink.runtime.rest.handler.job.checkpoints
org.apache.flink.runtime.rest.handler.job.coordination
org.apache.flink.runtime.rest.handler.job.metrics
org.apache.flink.runtime.rest.handler.job.rescaling
org.apache.flink.runtime.rest.handler.job.savepoints
org.apache.flink.runtime.rest.handler.legacy.files
org.apache.flink.runtime.rest.handler.resourcemanager
org.apache.flink.runtime.rest.handler.taskmanager
org.apache.flink.runtime.rest.handler.util

Uses of RestHandlerException in org.apache.flink.runtime.rest

Subclasses of RestHandlerException in org.apache.flink.runtime.rest

Modifier and Type	Class	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.

Uses of RestHandlerException in org.apache.flink.runtime.rest.handler

Methods in org.apache.flink.runtime.rest.handler that throw RestHandlerException

Modifier and Type	Method	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.

Uses of RestHandlerException in org.apache.flink.runtime.rest.handler.async

Methods in org.apache.flink.runtime.rest.handler.async that throw RestHandlerException

Modifier and Type	Method	Description
CompletableFuture<AsynchronousOperationResult<V>>	AbstractAsynchronousOperationHandlers.StatusHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, T gateway)
CompletableFuture<TriggerResponse>	AbstractAsynchronousOperationHandlers.TriggerHandler.handleRequest(HandlerRequest<B> request, T gateway)
protected abstract CompletableFuture<R>	AbstractAsynchronousOperationHandlers.TriggerHandler.triggerOperation(HandlerRequest<B> request, T gateway)	Trigger the asynchronous operation and return its future result.

Uses of RestHandlerException in org.apache.flink.runtime.rest.handler.cluster

Methods in org.apache.flink.runtime.rest.handler.cluster that throw RestHandlerException

Modifier and Type	Method	Description
protected CompletableFuture<ConfigurationInfo>	ClusterConfigHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected CompletableFuture<EnvironmentInfo>	JobManagerEnvironmentHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected CompletableFuture<LogListInfo>	JobManagerLogListHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected CompletableFuture<ThreadDumpInfo>	JobManagerThreadDumpHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected CompletableFuture<EmptyResponseBody>	ShutdownHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)

Uses of RestHandlerException in org.apache.flink.runtime.rest.handler.dataset

Methods in org.apache.flink.runtime.rest.handler.dataset that throw RestHandlerException

Modifier and Type	Method	Description
protected CompletableFuture<ClusterDataSetListResponseBody>	ClusterDataSetListHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, ResourceManagerGateway gateway)
protected CompletableFuture<ClusterDataSetDeleteHandlers.SerializableVoid>	ClusterDataSetDeleteHandlers.ClusterDataSetDeleteTriggerHandler.triggerOperation(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)

Uses of RestHandlerException in org.apache.flink.runtime.rest.handler.job

Methods in org.apache.flink.runtime.rest.handler.job that throw RestHandlerException

Modifier and Type	Method	Description
protected abstract R	AbstractAccessExecutionGraphHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionGraph executionGraph)
protected R	AbstractAccessExecutionGraphHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, ExecutionGraphInfo executionGraphInfo)
protected abstract R	AbstractExecutionGraphHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, ExecutionGraphInfo executionGraphInfo)	Called for each request after the corresponding ExecutionGraphInfo has been retrieved from the ExecutionGraphCache.
protected CompletableFuture<R>	AbstractExecutionGraphHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected R	AbstractJobVertexHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionGraph executionGraph)
protected abstract R	AbstractJobVertexHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionJobVertex jobVertex)	Called for each request after the corresponding AccessExecutionJobVertex has been retrieved from the AccessExecutionGraph.
protected abstract R	AbstractSubtaskAttemptHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecution execution)	Called for each request after the corresponding AccessExecution has been retrieved from the AccessExecutionVertex.
protected R	AbstractSubtaskAttemptHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionVertex executionVertex)
protected R	AbstractSubtaskHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionJobVertex jobVertex)
protected abstract R	AbstractSubtaskHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionVertex executionVertex)	Called for each request after the corresponding AccessExecutionVertex has been retrieved from the AccessExecutionJobVertex.
protected JobAccumulatorsInfo	JobAccumulatorsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionGraph graph)
CompletableFuture<EmptyResponseBody>	JobCancellationHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
CompletableFuture<EmptyResponseBody>	JobClientHeartbeatHandler.handleRequest(HandlerRequest<JobClientHeartbeatRequestBody> request, RestfulGateway gateway)
protected JobDetailsInfo	JobDetailsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionGraph executionGraph)
protected CompletableFuture<JobExecutionResultResponseBody>	JobExecutionResultHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected CompletableFuture<JobIdsWithStatusOverview>	JobIdsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected CompletableFuture<ConfigurationInfo>	JobManagerJobConfigurationHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected CompletableFuture<EnvironmentInfo>	JobManagerJobEnvironmentHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected JobPlanInfo	JobPlanHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionGraph executionGraph)
protected CompletableFuture<JobResourceRequirementsBody>	JobResourceRequirementsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected CompletableFuture<EmptyResponseBody>	JobResourceRequirementsUpdateHandler.handleRequest(HandlerRequest<JobResourceRequirementsBody> request, RestfulGateway gateway)
protected CompletableFuture<MultipleJobsDetails>	JobsOverviewHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected CompletableFuture<JobStatusInfo>	JobStatusHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected CompletableFuture<JobSubmitResponseBody>	JobSubmitHandler.handleRequest(HandlerRequest<JobSubmitRequestBody> request, DispatcherGateway gateway)
protected JobVertexAccumulatorsInfo	JobVertexAccumulatorsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionJobVertex jobVertex)
protected CompletableFuture<JobVertexBackPressureInfo>	JobVertexBackPressureHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected VertexFlameGraph	JobVertexFlameGraphHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionJobVertex jobVertex)
protected JobVertexTaskManagersInfo	JobVertexTaskManagersHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionGraph executionGraph)
protected SubtaskExecutionAttemptDetailsInfo	SubtaskCurrentAttemptDetailsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionVertex executionVertex)
protected SubtaskExecutionAttemptAccumulatorsInfo	SubtaskExecutionAttemptAccumulatorsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecution execution)
protected SubtaskExecutionAttemptDetailsInfo	SubtaskExecutionAttemptDetailsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecution execution)
protected SubtasksAllAccumulatorsInfo	SubtasksAllAccumulatorsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionJobVertex jobVertex)

Uses of RestHandlerException in org.apache.flink.runtime.rest.handler.job.checkpoints

Methods in org.apache.flink.runtime.rest.handler.job.checkpoints that throw RestHandlerException

Modifier and Type	Method	Description
protected abstract R	AbstractCheckpointHandler.handleCheckpointRequest(HandlerRequest<EmptyRequestBody> request, AbstractCheckpointStats checkpointStats)	Called for each request with the corresponding AbstractCheckpointStats instance.
protected TaskCheckpointStatisticsWithSubtaskDetails	TaskCheckpointStatisticDetailsHandler.handleCheckpointRequest(HandlerRequest<EmptyRequestBody> request, AbstractCheckpointStats checkpointStats)
protected R	AbstractCheckpointHandler.handleCheckpointStatsRequest(HandlerRequest<EmptyRequestBody> request, CheckpointStatsSnapshot checkpointStatsSnapshot)
protected abstract R	AbstractCheckpointStatsHandler.handleCheckpointStatsRequest(HandlerRequest<EmptyRequestBody> request, CheckpointStatsSnapshot checkpointStatsSnapshot)
protected CheckpointingStatistics	CheckpointingStatisticsHandler.handleCheckpointStatsRequest(HandlerRequest<EmptyRequestBody> request, CheckpointStatsSnapshot checkpointStatsSnapshot)
protected CompletableFuture<R>	AbstractCheckpointStatsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected CheckpointConfigInfo	CheckpointConfigHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionGraph executionGraph)
CompletableFuture<AsynchronousOperationResult<CheckpointInfo>>	CheckpointHandlers.CheckpointStatusHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected CompletableFuture<TriggerResponse>	CheckpointHandlers.CheckpointTriggerHandler.handleRequest(HandlerRequest<CheckpointTriggerRequestBody> request, RestfulGateway gateway)

Uses of RestHandlerException in org.apache.flink.runtime.rest.handler.job.coordination

Methods in org.apache.flink.runtime.rest.handler.job.coordination that throw RestHandlerException

Modifier and Type	Method	Description
protected CompletableFuture<ClientCoordinationResponseBody>	ClientCoordinationHandler.handleRequest(HandlerRequest<ClientCoordinationRequestBody> request, RestfulGateway gateway)

Uses of RestHandlerException in org.apache.flink.runtime.rest.handler.job.metrics

Methods in org.apache.flink.runtime.rest.handler.job.metrics that throw RestHandlerException

Modifier and Type	Method	Description
protected CompletableFuture<AggregatedMetricsResponseBody>	AbstractAggregatingMetricsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected CompletableFuture<MetricCollectionResponseBody>	AbstractMetricsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected MetricCollectionResponseBody	JobVertexWatermarksHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionJobVertex jobVertex)

Uses of RestHandlerException in org.apache.flink.runtime.rest.handler.job.rescaling

Methods in org.apache.flink.runtime.rest.handler.job.rescaling that throw RestHandlerException

Modifier and Type	Method	Description
CompletableFuture<AsynchronousOperationResult<AsynchronousOperationInfo>>	RescalingHandlers.RescalingStatusHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
CompletableFuture<TriggerResponse>	RescalingHandlers.RescalingTriggerHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)

Uses of RestHandlerException in org.apache.flink.runtime.rest.handler.job.savepoints

Methods in org.apache.flink.runtime.rest.handler.job.savepoints that throw RestHandlerException

Modifier and Type	Method	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)

Uses of RestHandlerException in org.apache.flink.runtime.rest.handler.legacy.files

Methods in org.apache.flink.runtime.rest.handler.legacy.files that throw RestHandlerException

Modifier and Type	Method	Description
static void	StaticFileServerHandler.checkFileValidity(File file, File rootPath, org.slf4j.Logger logger)	Checks various conditions for file access.

Uses of RestHandlerException in org.apache.flink.runtime.rest.handler.resourcemanager

Methods in org.apache.flink.runtime.rest.handler.resourcemanager that throw RestHandlerException

Modifier and Type	Method	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)

Uses of RestHandlerException in org.apache.flink.runtime.rest.handler.taskmanager

Methods in org.apache.flink.runtime.rest.handler.taskmanager that throw RestHandlerException

Modifier and Type	Method	Description
protected CompletableFuture<TaskManagerDetailsInfo>	TaskManagerDetailsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, ResourceManagerGateway gateway)
protected CompletableFuture<LogListInfo>	TaskManagerLogListHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, ResourceManagerGateway gateway)
protected CompletableFuture<TaskManagersInfo>	TaskManagersHandler.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)

Uses of RestHandlerException in org.apache.flink.runtime.rest.handler.util

Method parameters in org.apache.flink.runtime.rest.handler.util with type arguments of type RestHandlerException

Modifier and Type	Method	Description
static <T> T	HandlerRequestUtils.fromRequestBodyOrQueryParameter(T requestValue, org.apache.flink.util.function.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.

Methods in org.apache.flink.runtime.rest.handler.util that throw RestHandlerException

Modifier and Type	Method	Description
static <T> T	HandlerRequestUtils.fromRequestBodyOrQueryParameter(T requestValue, org.apache.flink.util.function.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> X	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> X	HandlerRequestUtils.getQueryParameter(HandlerRequest<R> request, Class<P> queryParameterClass, X defaultValue)