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

Packages that use HandlerRequest

Package	Description
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.job
org.apache.flink.runtime.rest.handler.job.checkpoints
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.taskmanager
org.apache.flink.runtime.rest.handler.util
org.apache.flink.runtime.webmonitor.handlers

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

Methods in org.apache.flink.runtime.rest.handler with parameters of type HandlerRequest

Modifier and Type	Method and Description
CompletableFuture<R>	LegacyRestHandler.handleRequest(HandlerRequest<EmptyRequestBody,M> request, T gateway)
protected CompletableFuture<R>	LegacyRestHandlerAdapter.handleRequest(HandlerRequest<EmptyRequestBody,M> request, T gateway)
protected abstract CompletableFuture<P>	AbstractRestHandler.handleRequest(HandlerRequest<R,M> 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,M> 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,M> handlerRequest, T gateway) Respond to the given HandlerRequest.

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

Methods in org.apache.flink.runtime.rest.handler.async with parameters of type HandlerRequest

Modifier and Type	Method and Description
protected abstract K	AbstractAsynchronousOperationHandlers.TriggerHandler.createOperationKey(HandlerRequest<B,M> 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,M> request) Extract the operation key under which the operation result future is stored.
CompletableFuture<TriggerResponse>	AbstractAsynchronousOperationHandlers.TriggerHandler.handleRequest(HandlerRequest<B,M> request, T gateway)
CompletableFuture<AsynchronousOperationResult<V>>	AbstractAsynchronousOperationHandlers.StatusHandler.handleRequest(HandlerRequest<EmptyRequestBody,M> request, T gateway)
protected abstract CompletableFuture<R>	AbstractAsynchronousOperationHandlers.TriggerHandler.triggerOperation(HandlerRequest<B,M> request, T gateway) Trigger the asynchronous operation and return its future result.

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

Methods in org.apache.flink.runtime.rest.handler.cluster with parameters of type HandlerRequest

Modifier and Type	Method and Description
CompletableFuture<DashboardConfiguration>	DashboardConfigHandler.handleRequest(HandlerRequest<EmptyRequestBody,EmptyMessageParameters> request, RestfulGateway gateway)
protected CompletableFuture<ClusterConfigurationInfo>	ClusterConfigHandler.handleRequest(HandlerRequest<EmptyRequestBody,EmptyMessageParameters> request, RestfulGateway gateway)
protected CompletableFuture<EmptyResponseBody>	ShutdownHandler.handleRequest(HandlerRequest<EmptyRequestBody,EmptyMessageParameters> request, RestfulGateway gateway)
CompletableFuture<ClusterOverviewWithVersion>	ClusterOverviewHandler.handleRequest(HandlerRequest<EmptyRequestBody,EmptyMessageParameters> request, RestfulGateway gateway)

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

Methods in org.apache.flink.runtime.rest.handler.job with parameters of type HandlerRequest

Modifier and Type	Method and Description
protected CompletableFuture<MultipleJobsDetails>	JobsOverviewHandler.handleRequest(HandlerRequest<EmptyRequestBody,EmptyMessageParameters> request, RestfulGateway gateway)
protected CompletableFuture<JobIdsWithStatusOverview>	JobIdsHandler.handleRequest(HandlerRequest<EmptyRequestBody,EmptyMessageParameters> request, RestfulGateway gateway)
protected JobAccumulatorsInfo	JobAccumulatorsHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobAccumulatorsMessageParameters> request, AccessExecutionGraph graph)
protected JobConfigInfo	JobConfigHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobMessageParameters> request, AccessExecutionGraph executionGraph)
protected JobPlanInfo	JobPlanHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobMessageParameters> request, AccessExecutionGraph executionGraph)
protected JobExceptionsInfo	JobExceptionsHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobMessageParameters> request, AccessExecutionGraph executionGraph)
protected JobDetailsInfo	JobDetailsHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobMessageParameters> request, AccessExecutionGraph executionGraph)
protected CompletableFuture<JobExecutionResultResponseBody>	JobExecutionResultHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobMessageParameters> request, RestfulGateway gateway)
CompletableFuture<EmptyResponseBody>	JobTerminationHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobTerminationMessageParameters> request, RestfulGateway gateway)
protected JobVertexTaskManagersInfo	JobVertexTaskManagersHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobVertexMessageParameters> request, AccessExecutionGraph executionGraph)
protected JobVertexDetailsInfo	JobVertexDetailsHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobVertexMessageParameters> request, AccessExecutionGraph executionGraph)
protected JobVertexAccumulatorsInfo	JobVertexAccumulatorsHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobVertexMessageParameters> request, AccessExecutionJobVertex jobVertex)
protected SubtasksTimesInfo	SubtasksTimesHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobVertexMessageParameters> request, AccessExecutionJobVertex jobVertex)
protected SubtasksAllAccumulatorsInfo	SubtasksAllAccumulatorsHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobVertexMessageParameters> request, AccessExecutionJobVertex jobVertex)
protected CompletableFuture<JobVertexBackPressureInfo>	JobVertexBackPressureHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobVertexMessageParameters> request, RestfulGateway gateway)
protected abstract R	AbstractSubtaskAttemptHandler.handleRequest(HandlerRequest<EmptyRequestBody,M> request, AccessExecution execution) Called for each request after the corresponding AccessExecution has been retrieved from the AccessExecutionVertex.
protected R	AbstractJobVertexHandler.handleRequest(HandlerRequest<EmptyRequestBody,M> request, AccessExecutionGraph executionGraph)
protected abstract R	AbstractExecutionGraphHandler.handleRequest(HandlerRequest<EmptyRequestBody,M> request, AccessExecutionGraph executionGraph) Called for each request after the corresponding AccessExecutionGraph has been retrieved from the ExecutionGraphCache.
protected abstract R	AbstractJobVertexHandler.handleRequest(HandlerRequest<EmptyRequestBody,M> request, AccessExecutionJobVertex jobVertex) Called for each request after the corresponding AccessExecutionJobVertex has been retrieved from the AccessExecutionGraph.
protected R	AbstractSubtaskHandler.handleRequest(HandlerRequest<EmptyRequestBody,M> request, AccessExecutionJobVertex jobVertex)
protected R	AbstractSubtaskAttemptHandler.handleRequest(HandlerRequest<EmptyRequestBody,M> request, AccessExecutionVertex executionVertex)
protected abstract R	AbstractSubtaskHandler.handleRequest(HandlerRequest<EmptyRequestBody,M> request, AccessExecutionVertex executionVertex) Called for each request after the corresponding AccessExecutionVertex has been retrieved from the AccessExecutionJobVertex.
protected CompletableFuture<R>	AbstractExecutionGraphHandler.handleRequest(HandlerRequest<EmptyRequestBody,M> request, RestfulGateway gateway)
protected SubtaskExecutionAttemptAccumulatorsInfo	SubtaskExecutionAttemptAccumulatorsHandler.handleRequest(HandlerRequest<EmptyRequestBody,SubtaskAttemptMessageParameters> request, AccessExecution execution)
protected SubtaskExecutionAttemptDetailsInfo	SubtaskExecutionAttemptDetailsHandler.handleRequest(HandlerRequest<EmptyRequestBody,SubtaskAttemptMessageParameters> request, AccessExecution execution)
protected SubtaskExecutionAttemptDetailsInfo	SubtaskCurrentAttemptDetailsHandler.handleRequest(HandlerRequest<EmptyRequestBody,SubtaskMessageParameters> request, AccessExecutionVertex executionVertex)
protected CompletableFuture<JobSubmitResponseBody>	JobSubmitHandler.handleRequest(HandlerRequest<JobSubmitRequestBody,EmptyMessageParameters> request, DispatcherGateway gateway)

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

Methods in org.apache.flink.runtime.rest.handler.job.checkpoints with parameters of type HandlerRequest

Modifier and Type	Method and Description
protected CheckpointStatistics	CheckpointStatisticDetailsHandler.handleCheckpointRequest(HandlerRequest<EmptyRequestBody,CheckpointMessageParameters> ignored, AbstractCheckpointStats checkpointStats)
protected abstract R	AbstractCheckpointHandler.handleCheckpointRequest(HandlerRequest<EmptyRequestBody,M> request, AbstractCheckpointStats checkpointStats) Called for each request with the corresponding AbstractCheckpointStats instance.
protected TaskCheckpointStatisticsWithSubtaskDetails	TaskCheckpointStatisticDetailsHandler.handleCheckpointRequest(HandlerRequest<EmptyRequestBody,TaskCheckpointMessageParameters> request, AbstractCheckpointStats checkpointStats)
protected CheckpointConfigInfo	CheckpointConfigHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobMessageParameters> request, AccessExecutionGraph executionGraph)
protected CheckpointingStatistics	CheckpointingStatisticsHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobMessageParameters> request, AccessExecutionGraph executionGraph)
protected R	AbstractCheckpointHandler.handleRequest(HandlerRequest<EmptyRequestBody,M> request, AccessExecutionGraph executionGraph)

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

Methods in org.apache.flink.runtime.rest.handler.job.metrics with parameters of type HandlerRequest

Modifier and Type	Method and Description
protected MetricStore.ComponentMetricStore	JobManagerMetricsHandler.getComponentMetricStore(HandlerRequest<EmptyRequestBody,JobManagerMetricsMessageParameters> request, MetricStore metricStore)
protected MetricStore.ComponentMetricStore	JobMetricsHandler.getComponentMetricStore(HandlerRequest<EmptyRequestBody,JobMetricsMessageParameters> request, MetricStore metricStore)
protected MetricStore.ComponentMetricStore	JobVertexMetricsHandler.getComponentMetricStore(HandlerRequest<EmptyRequestBody,JobVertexMetricsMessageParameters> request, MetricStore metricStore) Deprecated.
protected abstract MetricStore.ComponentMetricStore	AbstractMetricsHandler.getComponentMetricStore(HandlerRequest<EmptyRequestBody,M> request, MetricStore metricStore) Returns the MetricStore.ComponentMetricStore that should be queried for metrics.
protected MetricStore.ComponentMetricStore	SubtaskMetricsHandler.getComponentMetricStore(HandlerRequest<EmptyRequestBody,SubtaskMetricsMessageParameters> request, MetricStore metricStore)
protected MetricStore.ComponentMetricStore	TaskManagerMetricsHandler.getComponentMetricStore(HandlerRequest<EmptyRequestBody,TaskManagerMetricsMessageParameters> request, MetricStore metricStore)
protected CompletableFuture<MetricCollectionResponseBody>	AbstractMetricsHandler.handleRequest(HandlerRequest<EmptyRequestBody,M> request, RestfulGateway gateway)
protected CompletableFuture<AggregatedMetricsResponseBody>	AbstractAggregatingMetricsHandler.handleRequest(HandlerRequest<EmptyRequestBody,P> request, RestfulGateway gateway)

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

Methods in org.apache.flink.runtime.rest.handler.job.rescaling with parameters of type HandlerRequest

Modifier and Type	Method and Description
protected AsynchronousJobOperationKey	RescalingHandlers.RescalingTriggerHandler.createOperationKey(HandlerRequest<EmptyRequestBody,RescalingTriggerMessageParameters> request)
protected AsynchronousJobOperationKey	RescalingHandlers.RescalingStatusHandler.getOperationKey(HandlerRequest<EmptyRequestBody,RescalingStatusMessageParameters> request)
protected CompletableFuture<Acknowledge>	RescalingHandlers.RescalingTriggerHandler.triggerOperation(HandlerRequest<EmptyRequestBody,RescalingTriggerMessageParameters> request, RestfulGateway gateway)

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

Methods in org.apache.flink.runtime.rest.handler.job.savepoints with parameters of type HandlerRequest

Modifier and Type	Method and Description
protected OperationKey	SavepointDisposalHandlers.SavepointDisposalTriggerHandler.createOperationKey(HandlerRequest<SavepointDisposalRequest,EmptyMessageParameters> request)
protected AsynchronousJobOperationKey	SavepointHandlers.SavepointTriggerHandler.createOperationKey(HandlerRequest<SavepointTriggerRequestBody,SavepointTriggerMessageParameters> request)
protected OperationKey	SavepointDisposalHandlers.SavepointDisposalStatusHandler.getOperationKey(HandlerRequest<EmptyRequestBody,SavepointDisposalStatusMessageParameters> request)
protected AsynchronousJobOperationKey	SavepointHandlers.SavepointStatusHandler.getOperationKey(HandlerRequest<EmptyRequestBody,SavepointStatusMessageParameters> request)
protected CompletableFuture<Acknowledge>	SavepointDisposalHandlers.SavepointDisposalTriggerHandler.triggerOperation(HandlerRequest<SavepointDisposalRequest,EmptyMessageParameters> request, RestfulGateway gateway)
protected CompletableFuture<String>	SavepointHandlers.SavepointTriggerHandler.triggerOperation(HandlerRequest<SavepointTriggerRequestBody,SavepointTriggerMessageParameters> request, RestfulGateway gateway)

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

Methods in org.apache.flink.runtime.rest.handler.taskmanager with parameters of type HandlerRequest

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

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

Methods in org.apache.flink.runtime.rest.handler.util with parameters of type HandlerRequest

Modifier and Type	Method and Description
static <X,P extends MessageQueryParameter<X>,R extends RequestBody,M extends MessageParameters> X	HandlerRequestUtils.getQueryParameter(HandlerRequest<R,M> 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,M> request, Class<P> queryParameterClass, X defaultValue)

Uses of HandlerRequest in org.apache.flink.runtime.webmonitor.handlers

Methods in org.apache.flink.runtime.webmonitor.handlers with parameters of type HandlerRequest

Modifier and Type	Method and Description
protected CompletableFuture<JarListInfo>	JarListHandler.handleRequest(HandlerRequest<EmptyRequestBody,EmptyMessageParameters> request, RestfulGateway gateway)
protected CompletableFuture<JarUploadResponseBody>	JarUploadHandler.handleRequest(HandlerRequest<EmptyRequestBody,EmptyMessageParameters> request, RestfulGateway gateway)
protected CompletableFuture<EmptyResponseBody>	JarDeleteHandler.handleRequest(HandlerRequest<EmptyRequestBody,JarDeleteMessageParameters> request, RestfulGateway gateway)
protected CompletableFuture<JobPlanInfo>	JarPlanHandler.handleRequest(HandlerRequest<EmptyRequestBody,JarPlanMessageParameters> request, RestfulGateway gateway)
protected CompletableFuture<JarRunResponseBody>	JarRunHandler.handleRequest(HandlerRequest<JarRunRequestBody,JarRunMessageParameters> request, DispatcherGateway gateway)