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.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.resourcemanager
org.apache.flink.runtime.rest.handler.taskmanager
org.apache.flink.runtime.rest.handler.util
org.apache.flink.runtime.webmonitor.handlers
org.apache.flink.runtime.webmonitor.handlers.utils

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
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
protected File	JobManagerLogFileHandler.getFile(HandlerRequest<EmptyRequestBody,EmptyMessageParameters> handlerRequest)
protected File	JobManagerCustomLogHandler.getFile(HandlerRequest<EmptyRequestBody,FileMessageParameters> handlerRequest)
protected abstract File	AbstractJobManagerFileHandler.getFile(HandlerRequest<EmptyRequestBody,M> handlerRequest)
CompletableFuture<DashboardConfiguration>	DashboardConfigHandler.handleRequest(HandlerRequest<EmptyRequestBody,EmptyMessageParameters> request, RestfulGateway gateway)
protected CompletableFuture<EmptyResponseBody>	ShutdownHandler.handleRequest(HandlerRequest<EmptyRequestBody,EmptyMessageParameters> request, RestfulGateway gateway)
protected CompletableFuture<LogListInfo>	JobManagerLogListHandler.handleRequest(HandlerRequest<EmptyRequestBody,EmptyMessageParameters> request, RestfulGateway gateway)
CompletableFuture<ClusterOverviewWithVersion>	ClusterOverviewHandler.handleRequest(HandlerRequest<EmptyRequestBody,EmptyMessageParameters> request, RestfulGateway gateway)
protected CompletableFuture<ClusterConfigurationInfo>	ClusterConfigHandler.handleRequest(HandlerRequest<EmptyRequestBody,EmptyMessageParameters> request, RestfulGateway gateway)
protected CompletableFuture<Void>	AbstractJobManagerFileHandler.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.dataset

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

Modifier and Type	Method and Description
protected OperationKey	ClusterDataSetDeleteHandlers.ClusterDataSetDeleteTriggerHandler.createOperationKey(HandlerRequest<EmptyRequestBody,ClusterDataSetDeleteTriggerMessageParameters> request)
protected OperationKey	ClusterDataSetDeleteHandlers.ClusterDataSetDeleteStatusHandler.getOperationKey(HandlerRequest<EmptyRequestBody,ClusterDataSetDeleteStatusMessageParameters> request)
protected CompletableFuture<ClusterDataSetListResponseBody>	ClusterDataSetListHandler.handleRequest(HandlerRequest<EmptyRequestBody,EmptyMessageParameters> request, ResourceManagerGateway gateway)
protected CompletableFuture<Void>	ClusterDataSetDeleteHandlers.ClusterDataSetDeleteTriggerHandler.triggerOperation(HandlerRequest<EmptyRequestBody,ClusterDataSetDeleteTriggerMessageParameters> 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)
CompletableFuture<EmptyResponseBody>	JobCancellationHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobCancellationMessageParameters> request, RestfulGateway gateway)
protected JobExceptionsInfo	JobExceptionsHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobExceptionsMessageParameters> request, AccessExecutionGraph executionGraph)
protected JobDetailsInfo	JobDetailsHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobMessageParameters> request, AccessExecutionGraph executionGraph)
protected JobConfigInfo	JobConfigHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobMessageParameters> request, AccessExecutionGraph executionGraph)
protected JobPlanInfo	JobPlanHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobMessageParameters> request, AccessExecutionGraph executionGraph)
protected CompletableFuture<JobExecutionResultResponseBody>	JobExecutionResultHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobMessageParameters> request, RestfulGateway gateway)
protected JobVertexDetailsInfo	JobVertexDetailsHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobVertexMessageParameters> request, AccessExecutionGraph executionGraph)
protected JobVertexTaskManagersInfo	JobVertexTaskManagersHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobVertexMessageParameters> request, AccessExecutionGraph executionGraph)
protected SubtasksAllAccumulatorsInfo	SubtasksAllAccumulatorsHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobVertexMessageParameters> request, AccessExecutionJobVertex jobVertex)
protected SubtasksTimesInfo	SubtasksTimesHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobVertexMessageParameters> request, AccessExecutionJobVertex jobVertex)
protected JobVertexAccumulatorsInfo	JobVertexAccumulatorsHandler.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 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 R	AbstractJobVertexHandler.handleRequest(HandlerRequest<EmptyRequestBody,M> request, AccessExecutionGraph executionGraph)
protected R	AbstractSubtaskHandler.handleRequest(HandlerRequest<EmptyRequestBody,M> request, AccessExecutionJobVertex jobVertex)
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 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 R	AbstractSubtaskAttemptHandler.handleRequest(HandlerRequest<EmptyRequestBody,M> request, AccessExecutionVertex executionVertex)
protected CompletableFuture<R>	AbstractExecutionGraphHandler.handleRequest(HandlerRequest<EmptyRequestBody,M> request, RestfulGateway gateway)
protected SubtaskExecutionAttemptDetailsInfo	SubtaskExecutionAttemptDetailsHandler.handleRequest(HandlerRequest<EmptyRequestBody,SubtaskAttemptMessageParameters> request, AccessExecution execution)
protected SubtaskExecutionAttemptAccumulatorsInfo	SubtaskExecutionAttemptAccumulatorsHandler.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 CheckpointingStatistics	CheckpointingStatisticsHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobMessageParameters> request, AccessExecutionGraph executionGraph)
protected CheckpointConfigInfo	CheckpointConfigHandler.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.coordination

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

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

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 MetricCollectionResponseBody	JobVertexWatermarksHandler.handleRequest(HandlerRequest<EmptyRequestBody,JobVertexMessageParameters> request, AccessExecutionJobVertex jobVertex)
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)
CompletableFuture<AsynchronousOperationResult<AsynchronousOperationInfo>>	RescalingHandlers.RescalingStatusHandler.handleRequest(HandlerRequest<EmptyRequestBody,RescalingStatusMessageParameters> request, RestfulGateway gateway)
CompletableFuture<TriggerResponse>	RescalingHandlers.RescalingTriggerHandler.handleRequest(HandlerRequest<EmptyRequestBody,RescalingTriggerMessageParameters> request, RestfulGateway gateway)
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 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)
protected CompletableFuture<String>	SavepointHandlers.StopWithSavepointHandler.triggerOperation(HandlerRequest<StopWithSavepointRequestBody,SavepointTriggerMessageParameters> request, RestfulGateway gateway)

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

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

Modifier and Type	Method and Description
protected abstract CompletableFuture<P>	AbstractResourceManagerHandler.handleRequest(HandlerRequest<R,M> request, ResourceManagerGateway gateway)
protected CompletableFuture<P>	AbstractResourceManagerHandler.handleRequest(HandlerRequest<R,M> request, T 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 String	AbstractTaskManagerFileHandler.getFileName(HandlerRequest<EmptyRequestBody,M> handlerRequest)
protected String	TaskManagerCustomLogHandler.getFileName(HandlerRequest<EmptyRequestBody,TaskManagerFileMessageParameters> handlerRequest)
protected CompletableFuture<TaskManagersInfo>	TaskManagersHandler.handleRequest(HandlerRequest<EmptyRequestBody,EmptyMessageParameters> request, ResourceManagerGateway gateway)
protected CompletableFuture<TaskManagerDetailsInfo>	TaskManagerDetailsHandler.handleRequest(HandlerRequest<EmptyRequestBody,TaskManagerMessageParameters> request, ResourceManagerGateway gateway)
protected CompletableFuture<ThreadDumpInfo>	TaskManagerThreadDumpHandler.handleRequest(HandlerRequest<EmptyRequestBody,TaskManagerMessageParameters> request, ResourceManagerGateway gateway)
protected CompletableFuture<LogListInfo>	TaskManagerLogListHandler.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<JarPlanRequestBody,org.apache.flink.runtime.webmonitor.handlers.JarPlanMessageParameters> request, RestfulGateway gateway)
protected CompletableFuture<JarRunResponseBody>	JarRunHandler.handleRequest(HandlerRequest<JarRunRequestBody,JarRunMessageParameters> request, DispatcherGateway gateway)

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

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

Modifier and Type	Method and Description
static <R extends JarRequestBody> JarHandlerUtils.JarHandlerContext	JarHandlerUtils.JarHandlerContext.fromRequest(HandlerRequest<R,?> request, Path jarDir, org.slf4j.Logger log)