Uses of Class
org.apache.flink.runtime.rest.messages.EmptyRequestBody

Packages that use EmptyRequestBody

Package	Description
org.apache.flink.runtime.rest
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.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.messages
org.apache.flink.runtime.rest.messages.checkpoints
org.apache.flink.runtime.rest.messages.cluster
org.apache.flink.runtime.rest.messages.dataset
org.apache.flink.runtime.rest.messages.job
org.apache.flink.runtime.rest.messages.job.metrics
org.apache.flink.runtime.rest.messages.job.savepoints
org.apache.flink.runtime.rest.messages.taskmanager
org.apache.flink.runtime.webmonitor.handlers
org.apache.flink.table.gateway.rest.handler.operation
org.apache.flink.table.gateway.rest.handler.session
org.apache.flink.table.gateway.rest.handler.statement
org.apache.flink.table.gateway.rest.handler.util
org.apache.flink.table.gateway.rest.header.operation
org.apache.flink.table.gateway.rest.header.session
org.apache.flink.table.gateway.rest.header.statement
org.apache.flink.table.gateway.rest.header.util

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

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

Modifier and Type	Method and Description
<M extends MessageHeaders<EmptyRequestBody,P,EmptyMessageParameters>,P extends ResponseBody> CompletableFuture<P>	RestClient.sendRequest(String targetAddress, int targetPort, M messageHeaders)

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

Method parameters in org.apache.flink.runtime.rest.handler.async with type arguments of type EmptyRequestBody

Modifier and Type	Method and Description
protected abstract K	AbstractAsynchronousOperationHandlers.StatusHandler.getOperationKey(HandlerRequest<EmptyRequestBody> request) Extract the operation key under which the operation result future is stored.
CompletableFuture<AsynchronousOperationResult<V>>	AbstractAsynchronousOperationHandlers.StatusHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, T gateway)

Constructor parameters in org.apache.flink.runtime.rest.handler.async with type arguments of type EmptyRequestBody

Constructor and Description
StatusHandler(GatewayRetriever<? extends T> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,AsynchronousOperationResult<V>,M> messageHeaders)

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

Method parameters in org.apache.flink.runtime.rest.handler.cluster with type arguments of type EmptyRequestBody

Modifier and Type	Method and Description
protected File	JobManagerLogFileHandler.getFile(HandlerRequest<EmptyRequestBody> handlerRequest)
protected File	JobManagerCustomLogHandler.getFile(HandlerRequest<EmptyRequestBody> handlerRequest)
protected abstract File	AbstractJobManagerFileHandler.getFile(HandlerRequest<EmptyRequestBody> handlerRequest)
protected CompletableFuture<ThreadDumpInfo>	JobManagerThreadDumpHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected CompletableFuture<EmptyResponseBody>	ShutdownHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected CompletableFuture<ConfigurationInfo>	ClusterConfigHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected CompletableFuture<LogListInfo>	JobManagerLogListHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
CompletableFuture<DashboardConfiguration>	DashboardConfigHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
CompletableFuture<ClusterOverviewWithVersion>	ClusterOverviewHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected CompletableFuture<EnvironmentInfo>	JobManagerEnvironmentHandler.handleRequest(HandlerRequest<EmptyRequestBody> 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> handlerRequest, RestfulGateway gateway)

Constructor parameters in org.apache.flink.runtime.rest.handler.cluster with type arguments of type EmptyRequestBody

Constructor and Description
AbstractJobManagerFileHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, UntypedResponseMessageHeaders<EmptyRequestBody,M> messageHeaders)
ClusterConfigHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,ConfigurationInfo,EmptyMessageParameters> messageHeaders, Configuration configuration)
ClusterOverviewHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,ClusterOverviewWithVersion,EmptyMessageParameters> messageHeaders)
DashboardConfigHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,DashboardConfiguration,EmptyMessageParameters> messageHeaders, long refreshInterval, boolean webSubmitEnabled, boolean webCancelEnabled, boolean webRescaleEnabled)
JobManagerCustomLogHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, UntypedResponseMessageHeaders<EmptyRequestBody,FileMessageParameters> messageHeaders, File logDir)
JobManagerEnvironmentHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,EnvironmentInfo,EmptyMessageParameters> messageHeaders)
JobManagerLogFileHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, UntypedResponseMessageHeaders<EmptyRequestBody,EmptyMessageParameters> messageHeaders, File file)
JobManagerLogListHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,LogListInfo,EmptyMessageParameters> messageHeaders, File logDir)
JobManagerThreadDumpHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,ThreadDumpInfo,EmptyMessageParameters> messageHeaders)
ShutdownHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,EmptyResponseBody,EmptyMessageParameters> messageHeaders)

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

Method parameters in org.apache.flink.runtime.rest.handler.dataset with type arguments of type EmptyRequestBody

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)

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

Method parameters in org.apache.flink.runtime.rest.handler.job with type arguments of type EmptyRequestBody

Modifier and Type	Method and Description
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 SubtaskExecutionAttemptAccumulatorsInfo	SubtaskExecutionAttemptAccumulatorsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecution execution)
protected SubtaskExecutionAttemptDetailsInfo	SubtaskExecutionAttemptDetailsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecution execution)
protected R	AbstractJobVertexHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionGraph executionGraph)
protected JobDetailsInfo	JobDetailsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionGraph executionGraph)
protected JobPlanInfo	JobPlanHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionGraph executionGraph)
protected abstract R	AbstractAccessExecutionGraphHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionGraph executionGraph)
protected JobVertexTaskManagersInfo	JobVertexTaskManagersHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionGraph executionGraph)
protected JobAccumulatorsInfo	JobAccumulatorsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionGraph graph)
protected JobVertexDetailsInfo	JobVertexDetailsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionGraph executionGraph)
protected JobConfigInfo	JobConfigHandler.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 VertexFlameGraph	JobVertexFlameGraphHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionJobVertex jobVertex)
protected R	AbstractSubtaskHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionJobVertex jobVertex)
protected JobVertexAccumulatorsInfo	JobVertexAccumulatorsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionJobVertex jobVertex)
protected SubtasksAllAccumulatorsInfo	SubtasksAllAccumulatorsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionJobVertex jobVertex)
protected SubtasksTimesInfo	SubtasksTimesHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionJobVertex jobVertex)
protected R	AbstractSubtaskAttemptHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionVertex executionVertex)
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 SubtaskExecutionAttemptDetailsInfo	SubtaskCurrentAttemptDetailsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionVertex executionVertex)
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 R	AbstractAccessExecutionGraphHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, ExecutionGraphInfo executionGraphInfo)
protected JobExceptionsInfoWithHistory	JobExceptionsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, ExecutionGraphInfo executionGraph)
protected CompletableFuture<MultipleJobsDetails>	JobsOverviewHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected CompletableFuture<JobVertexBackPressureInfo>	JobVertexBackPressureHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected CompletableFuture<ConfigurationInfo>	JobManagerJobConfigurationHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
CompletableFuture<EmptyResponseBody>	JobCancellationHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected CompletableFuture<JobIdsWithStatusOverview>	JobIdsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected CompletableFuture<R>	AbstractExecutionGraphHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected CompletableFuture<JobResourceRequirementsBody>	JobResourceRequirementsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected CompletableFuture<EnvironmentInfo>	JobManagerJobEnvironmentHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected CompletableFuture<JobExecutionResultResponseBody>	JobExecutionResultHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected CompletableFuture<JobStatusInfo>	JobStatusHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)

Constructor parameters in org.apache.flink.runtime.rest.handler.job with type arguments of type EmptyRequestBody

Constructor and Description
AbstractAccessExecutionGraphHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,R,M> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
AbstractExecutionGraphHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,R,M> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
AbstractJobVertexHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,R,M> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor) Instantiates a new Abstract job vertex handler.
AbstractSubtaskAttemptHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,R,M> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor) Instantiates a new Abstract job vertex handler.
AbstractSubtaskHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,R,M> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor) Instantiates a new Abstract job vertex handler.
JobAccumulatorsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobAccumulatorsInfo,JobAccumulatorsMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
JobCancellationHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> headers, MessageHeaders<EmptyRequestBody,EmptyResponseBody,JobCancellationMessageParameters> messageHeaders, TerminationModeQueryParameter.TerminationMode defaultTerminationMode)
JobConfigHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobConfigInfo,JobMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
JobDetailsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobDetailsInfo,JobMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor, MetricFetcher metricFetcher)
JobExceptionsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobExceptionsInfoWithHistory,JobExceptionsMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
JobIdsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobIdsWithStatusOverview,EmptyMessageParameters> messageHeaders)
JobManagerJobConfigurationHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,ConfigurationInfo,JobMessageParameters> messageHeaders, Configuration configuration)
JobManagerJobEnvironmentHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,EnvironmentInfo,JobMessageParameters> messageHeaders)
JobPlanHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> headers, MessageHeaders<EmptyRequestBody,JobPlanInfo,JobMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
JobsOverviewHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,MultipleJobsDetails,EmptyMessageParameters> messageHeaders)
JobStatusHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobStatusInfo,JobMessageParameters> messageHeaders)
JobVertexAccumulatorsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobVertexAccumulatorsInfo,JobVertexMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
JobVertexBackPressureHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobVertexBackPressureInfo,JobVertexMessageParameters> messageHeaders, MetricFetcher metricFetcher)
JobVertexDetailsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobVertexDetailsInfo,JobVertexMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor, MetricFetcher metricFetcher)
JobVertexTaskManagersHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobVertexTaskManagersInfo,JobVertexMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor, MetricFetcher metricFetcher)
SubtaskCurrentAttemptDetailsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,SubtaskExecutionAttemptDetailsInfo,SubtaskMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor, MetricFetcher metricFetcher)
SubtaskExecutionAttemptAccumulatorsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,SubtaskExecutionAttemptAccumulatorsInfo,SubtaskAttemptMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor) Instantiates a new Abstract job vertex handler.
SubtaskExecutionAttemptDetailsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,SubtaskExecutionAttemptDetailsInfo,SubtaskAttemptMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor, MetricFetcher metricFetcher) Instantiates a new subtask execution attempt details handler.
SubtasksAllAccumulatorsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,SubtasksAllAccumulatorsInfo,JobVertexMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
SubtasksTimesHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,SubtasksTimesInfo,JobVertexMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)

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

Method parameters in org.apache.flink.runtime.rest.handler.job.checkpoints with type arguments of type EmptyRequestBody

Modifier and Type	Method and Description
protected abstract R	AbstractCheckpointHandler.handleCheckpointRequest(HandlerRequest<EmptyRequestBody> request, AbstractCheckpointStats checkpointStats) Called for each request with the corresponding AbstractCheckpointStats instance.
protected CheckpointStatistics	CheckpointStatisticDetailsHandler.handleCheckpointRequest(HandlerRequest<EmptyRequestBody> ignored, AbstractCheckpointStats checkpointStats)
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 CheckpointConfigInfo	CheckpointConfigHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionGraph executionGraph)
CompletableFuture<AsynchronousOperationResult<CheckpointInfo>>	CheckpointHandlers.CheckpointStatusHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)
protected CompletableFuture<R>	AbstractCheckpointStatsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)

Constructor parameters in org.apache.flink.runtime.rest.handler.job.checkpoints with type arguments of type EmptyRequestBody

Constructor and Description
AbstractCheckpointHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,R,M> messageHeaders, Executor executor, org.apache.flink.shaded.guava31.com.google.common.cache.Cache<JobID,CompletableFuture<CheckpointStatsSnapshot>> checkpointStatsSnapshotCache, CheckpointStatsCache checkpointStatsCache)
AbstractCheckpointStatsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,R,M> messageHeaders, org.apache.flink.shaded.guava31.com.google.common.cache.Cache<JobID,CompletableFuture<CheckpointStatsSnapshot>> checkpointStatsSnapshotCache, Executor executor)
CheckpointConfigHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,CheckpointConfigInfo,JobMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
CheckpointingStatisticsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,CheckpointingStatistics,JobMessageParameters> messageHeaders, org.apache.flink.shaded.guava31.com.google.common.cache.Cache<JobID,CompletableFuture<CheckpointStatsSnapshot>> checkpointStatsSnapshotCache, Executor executor)
CheckpointStatisticDetailsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,CheckpointStatistics,CheckpointMessageParameters> messageHeaders, Executor executor, org.apache.flink.shaded.guava31.com.google.common.cache.Cache<JobID,CompletableFuture<CheckpointStatsSnapshot>> checkpointStatsSnapshotCache, CheckpointStatsCache checkpointStatsCache)
TaskCheckpointStatisticDetailsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,TaskCheckpointStatisticsWithSubtaskDetails,TaskCheckpointMessageParameters> messageHeaders, Executor executor, org.apache.flink.shaded.guava31.com.google.common.cache.Cache<JobID,CompletableFuture<CheckpointStatsSnapshot>> checkpointStatsSnapshotCache, CheckpointStatsCache checkpointStatsCache)

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

Method parameters in org.apache.flink.runtime.rest.handler.job.metrics with type arguments of type EmptyRequestBody

Modifier and Type	Method and Description
protected MetricStore.ComponentMetricStore	TaskManagerMetricsHandler.getComponentMetricStore(HandlerRequest<EmptyRequestBody> request, MetricStore metricStore)
protected MetricStore.ComponentMetricStore	JobVertexMetricsHandler.getComponentMetricStore(HandlerRequest<EmptyRequestBody> request, MetricStore metricStore) Deprecated.
protected MetricStore.ComponentMetricStore	JobManagerMetricsHandler.getComponentMetricStore(HandlerRequest<EmptyRequestBody> request, MetricStore metricStore)
protected MetricStore.ComponentMetricStore	JobMetricsHandler.getComponentMetricStore(HandlerRequest<EmptyRequestBody> request, MetricStore metricStore)
protected abstract MetricStore.ComponentMetricStore	AbstractMetricsHandler.getComponentMetricStore(HandlerRequest<EmptyRequestBody> request, MetricStore metricStore) Returns the MetricStore.ComponentMetricStore that should be queried for metrics.
protected MetricStore.ComponentMetricStore	SubtaskMetricsHandler.getComponentMetricStore(HandlerRequest<EmptyRequestBody> request, MetricStore metricStore)
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)

Constructor parameters in org.apache.flink.runtime.rest.handler.job.metrics with type arguments of type EmptyRequestBody

Constructor and Description
AbstractMetricsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> headers, MessageHeaders<EmptyRequestBody,MetricCollectionResponseBody,M> messageHeaders, MetricFetcher metricFetcher)

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

Methods in org.apache.flink.runtime.rest.handler.job.rescaling that return types with arguments of type EmptyRequestBody

Modifier and Type	Method and Description
Class<EmptyRequestBody>	RescalingStatusHeaders.getRequestClass()
Class<EmptyRequestBody>	RescalingTriggerHeaders.getRequestClass()

Method parameters in org.apache.flink.runtime.rest.handler.job.rescaling with type arguments of type EmptyRequestBody

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)

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

Method parameters in org.apache.flink.runtime.rest.handler.job.savepoints with type arguments of type EmptyRequestBody

Modifier and Type	Method and Description
protected AsynchronousJobOperationKey	SavepointHandlers.SavepointStatusHandler.getOperationKey(HandlerRequest<EmptyRequestBody> request)
protected OperationKey	SavepointDisposalHandlers.SavepointDisposalStatusHandler.getOperationKey(HandlerRequest<EmptyRequestBody> request)
CompletableFuture<AsynchronousOperationResult<SavepointInfo>>	SavepointHandlers.SavepointStatusHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, RestfulGateway gateway)

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

Method parameters in org.apache.flink.runtime.rest.handler.taskmanager with type arguments of type EmptyRequestBody

Modifier and Type	Method and Description
protected String	TaskManagerCustomLogHandler.getFileName(HandlerRequest<EmptyRequestBody> handlerRequest)
protected String	AbstractTaskManagerFileHandler.getFileName(HandlerRequest<EmptyRequestBody> handlerRequest)
protected CompletableFuture<TaskManagerDetailsInfo>	TaskManagerDetailsHandler.handleRequest(HandlerRequest<EmptyRequestBody> request, ResourceManagerGateway gateway)
protected CompletableFuture<ThreadDumpInfo>	TaskManagerThreadDumpHandler.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<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)

Constructor parameters in org.apache.flink.runtime.rest.handler.taskmanager with type arguments of type EmptyRequestBody

Constructor and Description
AbstractTaskManagerFileHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, UntypedResponseMessageHeaders<EmptyRequestBody,M> untypedResponseMessageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, TransientBlobService transientBlobService, Time cacheEntryDuration)
TaskManagerCustomLogHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, UntypedResponseMessageHeaders<EmptyRequestBody,TaskManagerFileMessageParameters> untypedResponseMessageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, TransientBlobService transientBlobService, Time cacheEntryDuration)
TaskManagerDetailsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,TaskManagerDetailsInfo,TaskManagerMessageParameters> messageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, MetricFetcher metricFetcher)
TaskManagerLogFileHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, UntypedResponseMessageHeaders<EmptyRequestBody,TaskManagerMessageParameters> untypedResponseMessageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, TransientBlobService transientBlobService, Time cacheEntryDuration)
TaskManagerLogListHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,LogListInfo,TaskManagerMessageParameters> messageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever)
TaskManagersHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,TaskManagersInfo,EmptyMessageParameters> messageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever)
TaskManagerStdoutFileHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, UntypedResponseMessageHeaders<EmptyRequestBody,TaskManagerMessageParameters> untypedResponseMessageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, TransientBlobService transientBlobService, Time cacheEntryDuration)
TaskManagerThreadDumpHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,ThreadDumpInfo,TaskManagerMessageParameters> messageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever)

Uses of EmptyRequestBody in org.apache.flink.runtime.rest.messages

Methods in org.apache.flink.runtime.rest.messages that return EmptyRequestBody

Modifier and Type	Method and Description
static EmptyRequestBody	EmptyRequestBody.getInstance()

Methods in org.apache.flink.runtime.rest.messages that return types with arguments of type EmptyRequestBody

Modifier and Type	Method and Description
Class<EmptyRequestBody>	JobVertexBackPressureHeaders.getRequestClass()
Class<EmptyRequestBody>	ClusterOverviewHeaders.getRequestClass()
Class<EmptyRequestBody>	DashboardConfigurationHeaders.getRequestClass()
Class<EmptyRequestBody>	JobManagerLogUrlHeaders.getRequestClass()
Class<EmptyRequestBody>	TaskManagerLogUrlHeaders.getRequestClass()
Class<EmptyRequestBody>	JobVertexTaskManagersHeaders.getRequestClass()
Class<EmptyRequestBody>	JobAccumulatorsHeaders.getRequestClass()
Class<EmptyRequestBody>	JobExceptionsHeaders.getRequestClass()
Class<EmptyRequestBody>	JobManagerEnvironmentHeaders.getRequestClass()
Class<EmptyRequestBody>	JobsOverviewHeaders.getRequestClass()
Class<EmptyRequestBody>	JobIdsWithStatusesOverviewHeaders.getRequestClass()
Class<EmptyRequestBody>	SubtasksAllAccumulatorsHeaders.getRequestClass()
Class<EmptyRequestBody>	JobCancellationHeaders.getRequestClass()
Class<EmptyRequestBody>	JobVertexDetailsHeaders.getRequestClass()
Class<EmptyRequestBody>	ClusterConfigurationInfoHeaders.getRequestClass()
Class<EmptyRequestBody>	JobPlanHeaders.getRequestClass()
Class<EmptyRequestBody>	JobConfigHeaders.getRequestClass()
Class<EmptyRequestBody>	SubtasksTimesHeaders.getRequestClass()
Class<EmptyRequestBody>	JobVertexAccumulatorsHeaders.getRequestClass()
Class<EmptyRequestBody>	JobVertexFlameGraphHeaders.getRequestClass()

Uses of EmptyRequestBody in org.apache.flink.runtime.rest.messages.checkpoints

Methods in org.apache.flink.runtime.rest.messages.checkpoints that return types with arguments of type EmptyRequestBody

Modifier and Type	Method and Description
Class<EmptyRequestBody>	CheckpointStatusHeaders.getRequestClass()
Class<EmptyRequestBody>	CheckpointConfigHeaders.getRequestClass()
Class<EmptyRequestBody>	TaskCheckpointStatisticsHeaders.getRequestClass()
Class<EmptyRequestBody>	CheckpointStatisticDetailsHeaders.getRequestClass()
Class<EmptyRequestBody>	CheckpointingStatisticsHeaders.getRequestClass()

Uses of EmptyRequestBody in org.apache.flink.runtime.rest.messages.cluster

Methods in org.apache.flink.runtime.rest.messages.cluster that return types with arguments of type EmptyRequestBody

Modifier and Type	Method and Description
Class<EmptyRequestBody>	JobManagerLogFileHeader.getRequestClass()
Class<EmptyRequestBody>	ShutdownHeaders.getRequestClass()
Class<EmptyRequestBody>	JobManagerStdoutFileHeader.getRequestClass()
Class<EmptyRequestBody>	JobManagerCustomLogHeaders.getRequestClass()
Class<EmptyRequestBody>	JobManagerLogListHeaders.getRequestClass()
Class<EmptyRequestBody>	JobManagerThreadDumpHeaders.getRequestClass()

Uses of EmptyRequestBody in org.apache.flink.runtime.rest.messages.dataset

Methods in org.apache.flink.runtime.rest.messages.dataset that return types with arguments of type EmptyRequestBody

Modifier and Type	Method and Description
Class<EmptyRequestBody>	ClusterDataSetDeleteStatusHeaders.getRequestClass()
Class<EmptyRequestBody>	ClusterDataSetListHeaders.getRequestClass()
Class<EmptyRequestBody>	ClusterDataSetDeleteTriggerHeaders.getRequestClass()

Uses of EmptyRequestBody in org.apache.flink.runtime.rest.messages.job

Methods in org.apache.flink.runtime.rest.messages.job that return types with arguments of type EmptyRequestBody

Modifier and Type	Method and Description
Class<EmptyRequestBody>	JobManagerJobConfigurationHeaders.getRequestClass()
Class<EmptyRequestBody>	SubtaskCurrentAttemptDetailsHeaders.getRequestClass()
Class<EmptyRequestBody>	SubtaskExecutionAttemptDetailsHeaders.getRequestClass()
Class<EmptyRequestBody>	JobExecutionResultHeaders.getRequestClass()
Class<EmptyRequestBody>	JobStatusInfoHeaders.getRequestClass()
Class<EmptyRequestBody>	SubtaskExecutionAttemptAccumulatorsHeaders.getRequestClass()
Class<EmptyRequestBody>	JobDetailsHeaders.getRequestClass()
Class<EmptyRequestBody>	JobManagerJobEnvironmentHeaders.getRequestClass()
Class<EmptyRequestBody>	JobResourceRequirementsHeaders.getRequestClass()

Uses of EmptyRequestBody in org.apache.flink.runtime.rest.messages.job.metrics

Methods in org.apache.flink.runtime.rest.messages.job.metrics that return types with arguments of type EmptyRequestBody

Modifier and Type	Method and Description
Class<EmptyRequestBody>	AbstractAggregatedMetricsHeaders.getRequestClass()
Class<EmptyRequestBody>	JobVertexWatermarksHeaders.getRequestClass()
Class<EmptyRequestBody>	AbstractMetricsHeaders.getRequestClass()

Uses of EmptyRequestBody in org.apache.flink.runtime.rest.messages.job.savepoints

Methods in org.apache.flink.runtime.rest.messages.job.savepoints that return types with arguments of type EmptyRequestBody

Modifier and Type	Method and Description
Class<EmptyRequestBody>	SavepointDisposalStatusHeaders.getRequestClass()
Class<EmptyRequestBody>	SavepointStatusHeaders.getRequestClass()

Uses of EmptyRequestBody in org.apache.flink.runtime.rest.messages.taskmanager

Methods in org.apache.flink.runtime.rest.messages.taskmanager that return types with arguments of type EmptyRequestBody

Modifier and Type	Method and Description
Class<EmptyRequestBody>	TaskManagersHeaders.getRequestClass()
Class<EmptyRequestBody>	TaskManagerThreadDumpHeaders.getRequestClass()
Class<EmptyRequestBody>	TaskManagerDetailsHeaders.getRequestClass()
Class<EmptyRequestBody>	TaskManagerStdoutFileHeaders.getRequestClass()
Class<EmptyRequestBody>	TaskManagerLogsHeaders.getRequestClass()
Class<EmptyRequestBody>	TaskManagerLogFileHeaders.getRequestClass()
Class<EmptyRequestBody>	TaskManagerCustomLogHeaders.getRequestClass()

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

Methods in org.apache.flink.runtime.webmonitor.handlers that return types with arguments of type EmptyRequestBody

Modifier and Type	Method and Description
Class<EmptyRequestBody>	JarUploadHeaders.getRequestClass()
Class<EmptyRequestBody>	JarListHeaders.getRequestClass()
Class<EmptyRequestBody>	JarDeleteHeaders.getRequestClass()

Method parameters in org.apache.flink.runtime.webmonitor.handlers with type arguments of type EmptyRequestBody

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)

Constructor parameters in org.apache.flink.runtime.webmonitor.handlers with type arguments of type EmptyRequestBody

Constructor and Description
JarDeleteHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,EmptyResponseBody,JarDeleteMessageParameters> messageHeaders, Path jarDir, Executor executor)
JarListHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JarListInfo,EmptyMessageParameters> messageHeaders, CompletableFuture<String> localAddressFuture, File jarDir, Configuration configuration, Executor executor)
JarUploadHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JarUploadResponseBody,EmptyMessageParameters> messageHeaders, Path jarDir, Executor executor)

Uses of EmptyRequestBody in org.apache.flink.table.gateway.rest.handler.operation

Method parameters in org.apache.flink.table.gateway.rest.handler.operation with type arguments of type EmptyRequestBody

Modifier and Type	Method and Description
protected CompletableFuture<OperationStatusResponseBody>	AbstractOperationHandler.handleRequest(SqlGatewayRestAPIVersion version, HandlerRequest<EmptyRequestBody> request)

Constructor parameters in org.apache.flink.table.gateway.rest.handler.operation with type arguments of type EmptyRequestBody

Constructor and Description
AbstractOperationHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,OperationStatusResponseBody,OperationMessageParameters> messageHeaders)
CancelOperationHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,OperationStatusResponseBody,OperationMessageParameters> messageHeaders)
CloseOperationHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,OperationStatusResponseBody,OperationMessageParameters> messageHeaders)
GetOperationStatusHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,OperationStatusResponseBody,OperationMessageParameters> messageHeaders)

Uses of EmptyRequestBody in org.apache.flink.table.gateway.rest.handler.session

Method parameters in org.apache.flink.table.gateway.rest.handler.session with type arguments of type EmptyRequestBody

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)

Constructor parameters in org.apache.flink.table.gateway.rest.handler.session with type arguments of type EmptyRequestBody

Constructor and Description
CloseSessionHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,CloseSessionResponseBody,SessionMessageParameters> messageHeaders)
GetSessionConfigHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,GetSessionConfigResponseBody,SessionMessageParameters> messageHeaders)
TriggerSessionHeartbeatHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,EmptyResponseBody,SessionMessageParameters> messageHeaders)

Uses of EmptyRequestBody in org.apache.flink.table.gateway.rest.handler.statement

Method parameters in org.apache.flink.table.gateway.rest.handler.statement with type arguments of type EmptyRequestBody

Modifier and Type	Method and Description
protected CompletableFuture<FetchResultsResponseBody>	FetchResultsHandler.handleRequest(SqlGatewayRestAPIVersion version, HandlerRequest<EmptyRequestBody> request)

Constructor parameters in org.apache.flink.table.gateway.rest.handler.statement with type arguments of type EmptyRequestBody

Constructor and Description
FetchResultsHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,FetchResultsResponseBody,FetchResultsMessageParameters> messageHeaders)

Uses of EmptyRequestBody in org.apache.flink.table.gateway.rest.handler.util

Method parameters in org.apache.flink.table.gateway.rest.handler.util with type arguments of type EmptyRequestBody

Modifier and Type	Method and Description
protected CompletableFuture<GetApiVersionResponseBody>	GetApiVersionHandler.handleRequest(SqlGatewayRestAPIVersion version, HandlerRequest<EmptyRequestBody> request)
protected CompletableFuture<GetInfoResponseBody>	GetInfoHandler.handleRequest(SqlGatewayRestAPIVersion version, HandlerRequest<EmptyRequestBody> request)

Constructor parameters in org.apache.flink.table.gateway.rest.handler.util with type arguments of type EmptyRequestBody

Constructor and Description
GetApiVersionHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,GetApiVersionResponseBody,EmptyMessageParameters> messageHeaders)
GetApiVersionHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,GetApiVersionResponseBody,EmptyMessageParameters> messageHeaders, List<SqlGatewayRestAPIVersion> stableVersions)
GetInfoHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,GetInfoResponseBody,EmptyMessageParameters> messageHeaders)

Uses of EmptyRequestBody in org.apache.flink.table.gateway.rest.header.operation

Methods in org.apache.flink.table.gateway.rest.header.operation that return types with arguments of type EmptyRequestBody

Modifier and Type	Method and Description
Class<EmptyRequestBody>	AbstractOperationHeaders.getRequestClass()

Uses of EmptyRequestBody in org.apache.flink.table.gateway.rest.header.session

Methods in org.apache.flink.table.gateway.rest.header.session that return types with arguments of type EmptyRequestBody

Modifier and Type	Method and Description
Class<EmptyRequestBody>	TriggerSessionHeartbeatHeaders.getRequestClass()
Class<EmptyRequestBody>	CloseSessionHeaders.getRequestClass()
Class<EmptyRequestBody>	GetSessionConfigHeaders.getRequestClass()

Uses of EmptyRequestBody in org.apache.flink.table.gateway.rest.header.statement

Methods in org.apache.flink.table.gateway.rest.header.statement that return types with arguments of type EmptyRequestBody

Modifier and Type	Method and Description
Class<EmptyRequestBody>	FetchResultsHeaders.getRequestClass()

Uses of EmptyRequestBody in org.apache.flink.table.gateway.rest.header.util

Methods in org.apache.flink.table.gateway.rest.header.util that return types with arguments of type EmptyRequestBody

Modifier and Type	Method and Description
Class<EmptyRequestBody>	GetInfoHeaders.getRequestClass()
Class<EmptyRequestBody>	GetApiVersionHeaders.getRequestClass()