Uses of Interface
org.apache.flink.runtime.rest.messages.MessageHeaders

Packages that use MessageHeaders

Package	Description
org.apache.flink.client.program.rest
org.apache.flink.docs.rest
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.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.resourcemanager
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.coordination
org.apache.flink.runtime.rest.messages.job.metrics
org.apache.flink.runtime.rest.messages.job.savepoints
org.apache.flink.runtime.rest.messages.job.savepoints.stop
org.apache.flink.runtime.rest.messages.taskmanager
org.apache.flink.runtime.webmonitor.handlers
org.apache.flink.table.gateway.rest.handler
org.apache.flink.table.gateway.rest.handler.materializedtable
org.apache.flink.table.gateway.rest.handler.materializedtable.scheduler
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
org.apache.flink.table.gateway.rest.header.materializedtable
org.apache.flink.table.gateway.rest.header.materializedtable.scheduler
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 MessageHeaders in org.apache.flink.client.program.rest

Classes in org.apache.flink.client.program.rest that implement MessageHeaders

Modifier and Type	Class	Description
class	UrlPrefixDecorator<R extends RequestBody,P extends ResponseBody,M extends MessageParameters>	This class decorates the URL of the original message headers by adding a prefix.

Methods in org.apache.flink.client.program.rest with type parameters of type MessageHeaders

Modifier and Type	Method	Description
<M extends MessageHeaders<R,P,U>,U extends MessageParameters,R extends RequestBody,P extends ResponseBody> CompletableFuture<P>	RestClusterClient.sendRequest(M messageHeaders, U messageParameters, R request)

Methods in org.apache.flink.client.program.rest that return MessageHeaders

Modifier and Type	Method	Description
MessageHeaders<R,P,M>	UrlPrefixDecorator.getDecorated()

Constructors in org.apache.flink.client.program.rest with parameters of type MessageHeaders

Constructor	Description
UrlPrefixDecorator(MessageHeaders<R,P,M> messageHeaders, String urlPrefix)	Constructs an instance of UrlPrefixDecorator.

Uses of MessageHeaders in org.apache.flink.docs.rest

Methods in org.apache.flink.docs.rest with parameters of type MessageHeaders

Modifier and Type	Method	Description
static boolean	ApiSpecGeneratorUtils.shouldBeDocumented(MessageHeaders<? extends RequestBody,? extends ResponseBody,? extends MessageParameters> spec)	Checks whether the given endpoint should be documented.

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

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

Modifier and Type	Method	Description
<M extends MessageHeaders<EmptyRequestBody,P,EmptyMessageParameters>,P extends ResponseBody> CompletableFuture<P>	RestClient.sendRequest(String targetAddress, int targetPort, M messageHeaders)
<M extends MessageHeaders<R,P,U>,U extends MessageParameters,R extends RequestBody,P extends ResponseBody> CompletableFuture<P>	RestClient.sendRequest(String targetAddress, int targetPort, M messageHeaders, U messageParameters, R request)
<M extends MessageHeaders<R,P,U>,U extends MessageParameters,R extends RequestBody,P extends ResponseBody> CompletableFuture<P>	RestClient.sendRequest(String targetAddress, int targetPort, M messageHeaders, U messageParameters, R request, Collection<FileUpload> fileUploads)
<M extends MessageHeaders<R,P,U>,U extends MessageParameters,R extends RequestBody,P extends ResponseBody> CompletableFuture<P>	RestClient.sendRequest(String targetAddress, int targetPort, M messageHeaders, U messageParameters, R request, Collection<FileUpload> fileUploads, RestAPIVersion<? extends RestAPIVersion<?>> apiVersion)

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

Methods in org.apache.flink.runtime.rest.handler that return MessageHeaders

Modifier and Type	Method	Description
MessageHeaders<R,P,M>	AbstractRestHandler.getMessageHeaders()

Constructors in org.apache.flink.runtime.rest.handler with parameters of type MessageHeaders

Constructor	Description
AbstractRestHandler(GatewayRetriever<? extends T> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<R,P,M> messageHeaders)

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

Classes in org.apache.flink.runtime.rest.handler.async that implement MessageHeaders

Modifier and Type	Class	Description
class	AsynchronousOperationStatusMessageHeaders<V,M extends MessageParameters>	Message headers for the status polling of an asynchronous operation.
class	AsynchronousOperationTriggerMessageHeaders<R extends RequestBody,M extends MessageParameters>	Message headers for the triggering of an asynchronous operation.

Constructors in org.apache.flink.runtime.rest.handler.async with parameters of type MessageHeaders

Constructor	Description
StatusHandler(GatewayRetriever<? extends T> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,AsynchronousOperationResult<V>,M> messageHeaders)
TriggerHandler(GatewayRetriever<? extends T> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<B,TriggerResponse,M> messageHeaders)

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

Constructors in org.apache.flink.runtime.rest.handler.cluster with parameters of type MessageHeaders

Constructor	Description
ClusterConfigHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,ConfigurationInfo,EmptyMessageParameters> messageHeaders, Configuration configuration)
ClusterOverviewHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,ClusterOverviewWithVersion,EmptyMessageParameters> messageHeaders)
DashboardConfigHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,DashboardConfiguration,EmptyMessageParameters> messageHeaders, long refreshInterval, boolean webSubmitEnabled, boolean webCancelEnabled, boolean webRescaleEnabled)
JobManagerEnvironmentHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,EnvironmentInfo,EmptyMessageParameters> messageHeaders)
JobManagerLogListHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,LogListInfo,EmptyMessageParameters> messageHeaders, File logDir)
JobManagerProfilingHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<ProfilingRequestBody,ProfilingInfo,EmptyMessageParameters> messageHeaders, Configuration configuration)
JobManagerProfilingListHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,ProfilingInfoList,EmptyMessageParameters> messageHeaders, Configuration configuration)
JobManagerThreadDumpHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,ThreadDumpInfo,EmptyMessageParameters> messageHeaders)
ShutdownHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,EmptyResponseBody,EmptyMessageParameters> messageHeaders)

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

Constructors in org.apache.flink.runtime.rest.handler.job with parameters of type MessageHeaders

Constructor	Description
AbstractAccessExecutionGraphHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,R,M> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
AbstractExecutionGraphHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,R,M> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
AbstractJobVertexHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration 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, Duration 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, Duration 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, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobAccumulatorsInfo,JobAccumulatorsMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
JobCancellationHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> headers, MessageHeaders<EmptyRequestBody,EmptyResponseBody,JobCancellationMessageParameters> messageHeaders, TerminationModeQueryParameter.TerminationMode defaultTerminationMode)
JobClientHeartbeatHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> headers, MessageHeaders<JobClientHeartbeatRequestBody,EmptyResponseBody,JobClientHeartbeatParameters> messageHeaders)
JobConfigHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobConfigInfo,JobMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
JobDetailsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobDetailsInfo,JobMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor, MetricFetcher metricFetcher)
JobExceptionsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobExceptionsInfoWithHistory,JobExceptionsMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
JobIdsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobIdsWithStatusOverview,EmptyMessageParameters> messageHeaders)
JobManagerJobConfigurationHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,ConfigurationInfo,JobMessageParameters> messageHeaders, Configuration configuration)
JobManagerJobEnvironmentHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,EnvironmentInfo,JobMessageParameters> messageHeaders)
JobPlanHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> headers, MessageHeaders<EmptyRequestBody,JobPlanInfo,JobMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
JobsOverviewHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,MultipleJobsDetails,EmptyMessageParameters> messageHeaders)
JobStatusHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobStatusInfo,JobMessageParameters> messageHeaders)
JobVertexAccumulatorsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobVertexAccumulatorsInfo,JobVertexMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
JobVertexBackPressureHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobVertexBackPressureInfo,JobVertexMessageParameters> messageHeaders, MetricFetcher metricFetcher)
JobVertexDetailsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobVertexDetailsInfo,JobVertexMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor, MetricFetcher metricFetcher)
JobVertexTaskManagersHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobVertexTaskManagersInfo,JobVertexMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor, MetricFetcher metricFetcher)
SubtaskCurrentAttemptDetailsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,SubtaskExecutionAttemptDetailsInfo,SubtaskMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor, MetricFetcher metricFetcher)
SubtaskExecutionAttemptAccumulatorsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration 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, Duration 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, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,SubtasksAllAccumulatorsInfo,JobVertexMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
SubtasksTimesHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,SubtasksTimesInfo,JobVertexMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)

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

Constructors in org.apache.flink.runtime.rest.handler.job.checkpoints with parameters of type MessageHeaders

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

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

Constructors in org.apache.flink.runtime.rest.handler.job.coordination with parameters of type MessageHeaders

Constructor	Description
ClientCoordinationHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<ClientCoordinationRequestBody,ClientCoordinationResponseBody,ClientCoordinationMessageParameters> messageHeaders)

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

Constructors in org.apache.flink.runtime.rest.handler.job.metrics with parameters of type MessageHeaders

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

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

Classes in org.apache.flink.runtime.rest.handler.job.rescaling that implement MessageHeaders

Modifier and Type	Class	Description
class	RescalingStatusHeaders	Message headers for polling the status of an ongoing rescaling operation.
class	RescalingTriggerHeaders	Message headers for triggering the rescaling of a job.

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

Constructors in org.apache.flink.runtime.rest.handler.resourcemanager with parameters of type MessageHeaders

Constructor	Description
AbstractResourceManagerHandler(GatewayRetriever<? extends T> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<R,P,M> messageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever)

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

Constructors in org.apache.flink.runtime.rest.handler.taskmanager with parameters of type MessageHeaders

Constructor	Description
TaskManagerDetailsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,TaskManagerDetailsInfo,TaskManagerMessageParameters> messageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, MetricFetcher metricFetcher)
TaskManagerLogListHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,LogListInfo,TaskManagerMessageParameters> messageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever)
TaskManagerProfilingHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<ProfilingRequestBody,ProfilingInfo,TaskManagerMessageParameters> messageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, Configuration configuration)
TaskManagerProfilingListHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,ProfilingInfoList,TaskManagerMessageParameters> messageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever)
TaskManagersHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,TaskManagersInfo,EmptyMessageParameters> messageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever)
TaskManagerThreadDumpHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,ThreadDumpInfo,TaskManagerMessageParameters> messageHeaders, GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever)

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

Subinterfaces of MessageHeaders in org.apache.flink.runtime.rest.messages

Modifier and Type	Interface	Description
interface	RuntimeMessageHeaders<R extends RequestBody,P extends ResponseBody,M extends MessageParameters>	This class links RequestBodys to ResponseBodys types and contains meta-data required for their http headers in runtime module.

Classes in org.apache.flink.runtime.rest.messages that implement MessageHeaders

Modifier and Type	Class	Description
class	ClusterConfigurationInfoHeaders	Message headers for the ClusterConfigHandler.
class	ClusterOverviewHeaders	Message headers for the ClusterOverviewHandler.
class	CustomHeadersDecorator<R extends RequestBody,P extends ResponseBody,M extends MessageParameters>	Decorator class for MessageHeaders that adds the ability to include custom HTTP headers.
class	DashboardConfigurationHeaders	Message headers for the DashboardConfigHandler.
class	JobAccumulatorsHeaders	Message headers for the JobAccumulatorsHandler.
class	JobCancellationHeaders	Message headers for the JobCancellationHandler.
class	JobClientHeartbeatHeaders	Message headers for the JobClientHeartbeatHandler.
class	JobConfigHeaders	Message headers for the JobConfigHandler.
class	JobExceptionsHeaders	Message headers for the JobExceptionsHandler.
class	JobIdsWithStatusesOverviewHeaders	Message headers for the JobIdsWithStatusOverview.
class	JobManagerEnvironmentHeaders	Message headers for the JobManagerEnvironmentHandler.
class	JobManagerLogUrlHeaders	Headers for the log url retriever of JobManager.
class	JobPlanHeaders	Message headers for the JobPlanHandler.
class	JobsOverviewHeaders	Message headers for JobsOverviewHandler.
class	JobVertexAccumulatorsHeaders	Message headers for the JobVertexAccumulatorsHandler.
class	JobVertexBackPressureHeaders	Message headers for the JobVertexBackPressureHandler.
class	JobVertexDetailsHeaders	Message headers for the JobVertexDetailsHandler.
class	JobVertexFlameGraphHeaders	Message headers for the JobVertexFlameGraphHandler.
class	JobVertexTaskManagersHeaders	Message headers for the JobVertexTaskManagersHandler.
class	SubtasksAllAccumulatorsHeaders	Message headers for the SubtasksAllAccumulatorsHandler.
class	SubtasksTimesHeaders	Message headers for the SubtasksTimesHandler.
class	TaskManagerLogUrlHeaders	Headers for the log url retriever of TaskManager.

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

Modifier and Type	Method	Description
MessageHeaders<R,P,M>	CustomHeadersDecorator.getDecorated()

Constructors in org.apache.flink.runtime.rest.messages with parameters of type MessageHeaders

Constructor	Description
CustomHeadersDecorator(MessageHeaders<R,P,M> decorated)	Creates a new CustomHeadersDecorator for a given MessageHeaders object.

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

Classes in org.apache.flink.runtime.rest.messages.checkpoints that implement MessageHeaders

Modifier and Type	Class	Description
class	CheckpointConfigHeaders	Message headers for the CheckpointConfigHandler.
class	CheckpointingStatisticsHeaders	Message headers for the CheckpointingStatisticsHandler.
class	CheckpointStatisticDetailsHeaders	Headers for the CheckpointStatisticDetailsHandler.
class	CheckpointStatusHeaders	These headers define the protocol for querying the status of a checkpoint operation.
class	CheckpointTriggerHeaders	These headers define the protocol for triggering a checkpoint.
class	TaskCheckpointStatisticsHeaders	Headers for the TaskCheckpointStatisticDetailsHandler.

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

Classes in org.apache.flink.runtime.rest.messages.cluster that implement MessageHeaders

Modifier and Type	Class	Description
class	JobManagerLogListHeaders	Headers for the JobManagerLogListHandler.
class	JobManagerProfilingHeaders	Headers for the JobManagerProfilingHandler.
class	JobManagerProfilingListHeaders	Headers for the JobManagerProfilingHandler.
class	JobManagerThreadDumpHeaders	Headers for the JobManagerThreadDumpHandler.
class	ShutdownHeaders	Message headers for ShutdownHandler.

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

Classes in org.apache.flink.runtime.rest.messages.dataset that implement MessageHeaders

Modifier and Type	Class	Description
class	ClusterDataSetDeleteStatusHeaders	Specification for retrieving the status for the delete operation of a cluster data set.
class	ClusterDataSetDeleteTriggerHeaders	Specification for triggering the deletion of a cluster data set.
class	ClusterDataSetListHeaders	Specification for retrieving an overview over all available cluster partitions.

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

Classes in org.apache.flink.runtime.rest.messages.job that implement MessageHeaders

Modifier and Type	Class	Description
class	JobDetailsHeaders	Message headers for the JobDetailsHandler.
class	JobExecutionResultHeaders	MessageHeaders for JobExecutionResultHeaders.
class	JobManagerJobConfigurationHeaders	Message headers for the JobManagerJobConfigurationHandler.
class	JobManagerJobEnvironmentHeaders	Message headers for the JobManagerJobEnvironmentHandler.
class	JobResourceRequirementsHeaders	Headers for REST request to get details on job's resources.
class	JobResourcesRequirementsUpdateHeaders	Headers for REST request to patch a job.
class	JobStatusInfoHeaders	MessageHeaders for JobStatusHandler.
class	JobSubmitHeaders	These headers define the protocol for submitting a job to a flink cluster.
class	SubtaskCurrentAttemptDetailsHeaders	Message headers for the SubtaskCurrentAttemptDetailsHandler.
class	SubtaskExecutionAttemptAccumulatorsHeaders	Message headers for the SubtaskExecutionAttemptAccumulatorsHandler.
class	SubtaskExecutionAttemptDetailsHeaders	Message headers for the SubtaskExecutionAttemptDetailsHandler.

Uses of MessageHeaders in org.apache.flink.runtime.rest.messages.job.coordination

Classes in org.apache.flink.runtime.rest.messages.job.coordination that implement MessageHeaders

Modifier and Type	Class	Description
class	ClientCoordinationHeaders	Message headers for the ClientCoordinationHandler.

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

Classes in org.apache.flink.runtime.rest.messages.job.metrics that implement MessageHeaders

Modifier and Type	Class	Description
class	AbstractAggregatedMetricsHeaders<P extends AbstractAggregatedMetricsParameters<?>>	Based MessageHeaders class for aggregating metrics.
class	AbstractMetricsHeaders<M extends MessageParameters>	MessageHeaders for AbstractMetricsHandler.
class	AggregatedJobMetricsHeaders	Headers for aggregating job metrics.
class	AggregatedSubtaskMetricsHeaders	Headers for aggregating subtask metrics.
class	AggregatedTaskManagerMetricsHeaders	Headers for aggregating task manager metrics.
class	JobManagerMetricsHeaders	MessageHeaders for JobManagerMetricsHandler.
class	JobManagerOperatorMetricsHeaders	MessageHeaders for JobManagerOperatorMetricsHandler.
class	JobMetricsHeaders	MessageHeaders for JobMetricsHandler.
class	JobVertexMetricsHeaders	MessageHeaders for JobVertexMetricsHandler.
class	JobVertexWatermarksHeaders	MessageHeaders for retrieving watermarks.
class	SubtaskMetricsHeaders	MessageHeaders for SubtaskMetricsHandler.
class	TaskManagerMetricsHeaders	MessageHeaders for TaskManagerMetricsHandler.

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

Classes in org.apache.flink.runtime.rest.messages.job.savepoints that implement MessageHeaders

Modifier and Type	Class	Description
class	SavepointDisposalStatusHeaders	AsynchronousOperationTriggerMessageHeaders implementation for the SavepointDisposalHandlers.SavepointDisposalStatusHandler.
class	SavepointDisposalTriggerHeaders	AsynchronousOperationTriggerMessageHeaders for the SavepointDisposalHandlers.SavepointDisposalTriggerHandler.
class	SavepointStatusHeaders	These headers define the protocol for triggering a savepoint.
class	SavepointTriggerHeaders	These headers define the protocol for triggering a savepoint.

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

Classes in org.apache.flink.runtime.rest.messages.job.savepoints.stop that implement MessageHeaders

Modifier and Type	Class	Description
class	StopWithSavepointTriggerHeaders	These headers define the protocol for triggering a "stop" action.

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

Classes in org.apache.flink.runtime.rest.messages.taskmanager that implement MessageHeaders

Modifier and Type	Class	Description
class	TaskManagerDetailsHeaders	Headers for the TaskManagerDetailsHandler which serves the TaskManager details.
class	TaskManagerLogsHeaders	Headers for the TaskManagerLogListHandler.
class	TaskManagerProfilingHeaders	Headers for the TaskManagerProfilingHandler.
class	TaskManagerProfilingListHeaders	Headers for the TaskManagerProfilingListHandler.
class	TaskManagersHeaders	Message headers for the TaskManagersHandler.
class	TaskManagerThreadDumpHeaders	Headers for the TaskManagerThreadDumpHandler.

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

Classes in org.apache.flink.runtime.webmonitor.handlers that implement MessageHeaders

Modifier and Type	Class	Description
class	AbstractJarPlanHeaders	Message headers for JarPlanHandler.
class	JarDeleteHeaders	Message headers for JarDeleteHandler.
class	JarListHeaders	Message headers for the JarListHandler.
class	JarPlanGetHeaders	Message headers for JarPlanHandler.
class	JarPlanPostHeaders	Message headers for JarPlanHandler.
class	JarRunHeaders	MessageHeaders for JarRunHandler.
class	JarUploadHeaders	MessageHeaders for uploading jars.

Constructors in org.apache.flink.runtime.webmonitor.handlers with parameters of type MessageHeaders

Constructor	Description
JarDeleteHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,EmptyResponseBody,JarDeleteMessageParameters> messageHeaders, Path jarDir, Executor executor)
JarListHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JarListInfo,EmptyMessageParameters> messageHeaders, CompletableFuture<String> localAddressFuture, File jarDir, Configuration configuration, Executor executor)
JarPlanHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<JarPlanRequestBody,JobPlanInfo,org.apache.flink.runtime.webmonitor.handlers.JarPlanMessageParameters> messageHeaders, Path jarDir, Configuration configuration, Executor executor)
JarPlanHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<JarPlanRequestBody,JobPlanInfo,org.apache.flink.runtime.webmonitor.handlers.JarPlanMessageParameters> messageHeaders, Path jarDir, Configuration configuration, Executor executor, Function<JobGraph,JobPlanInfo> planGenerator)
JarRunHandler(GatewayRetriever<? extends DispatcherGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<JarRunRequestBody,JarRunResponseBody,JarRunMessageParameters> messageHeaders, Path jarDir, Configuration configuration, Executor executor, Supplier<ApplicationRunner> applicationRunnerSupplier)
JarUploadHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JarUploadResponseBody,EmptyMessageParameters> messageHeaders, Path jarDir, Executor executor)

Uses of MessageHeaders in org.apache.flink.table.gateway.rest.handler

Constructors in org.apache.flink.table.gateway.rest.handler with parameters of type MessageHeaders

Constructor	Description
AbstractSqlGatewayRestHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<R,P,M> messageHeaders)

Uses of MessageHeaders in org.apache.flink.table.gateway.rest.handler.materializedtable

Constructors in org.apache.flink.table.gateway.rest.handler.materializedtable with parameters of type MessageHeaders

Constructor	Description
RefreshMaterializedTableHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<RefreshMaterializedTableRequestBody,RefreshMaterializedTableResponseBody,RefreshMaterializedTableParameters> messageHeaders)

Uses of MessageHeaders in org.apache.flink.table.gateway.rest.handler.materializedtable.scheduler

Constructors in org.apache.flink.table.gateway.rest.handler.materializedtable.scheduler with parameters of type MessageHeaders

Constructor	Description
CreateEmbeddedSchedulerWorkflowHandler(SqlGatewayService service, EmbeddedQuartzScheduler quartzScheduler, Map<String,String> responseHeaders, MessageHeaders<CreateEmbeddedSchedulerWorkflowRequestBody,CreateEmbeddedSchedulerWorkflowResponseBody,EmptyMessageParameters> messageHeaders)
DeleteEmbeddedSchedulerWorkflowHandler(SqlGatewayService service, EmbeddedQuartzScheduler quartzScheduler, Map<String,String> responseHeaders, MessageHeaders<EmbeddedSchedulerWorkflowRequestBody,EmptyResponseBody,EmptyMessageParameters> messageHeaders)
ResumeEmbeddedSchedulerWorkflowHandler(SqlGatewayService service, EmbeddedQuartzScheduler quartzScheduler, Map<String,String> responseHeaders, MessageHeaders<ResumeEmbeddedSchedulerWorkflowRequestBody,EmptyResponseBody,EmptyMessageParameters> messageHeaders)
SuspendEmbeddedSchedulerWorkflowHandler(SqlGatewayService service, EmbeddedQuartzScheduler quartzScheduler, Map<String,String> responseHeaders, MessageHeaders<EmbeddedSchedulerWorkflowRequestBody,EmptyResponseBody,EmptyMessageParameters> messageHeaders)

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

Constructors in org.apache.flink.table.gateway.rest.handler.operation with parameters of type MessageHeaders

Constructor	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 MessageHeaders in org.apache.flink.table.gateway.rest.handler.session

Constructors in org.apache.flink.table.gateway.rest.handler.session with parameters of type MessageHeaders

Constructor	Description
CloseSessionHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,CloseSessionResponseBody,SessionMessageParameters> messageHeaders)
ConfigureSessionHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<ConfigureSessionRequestBody,EmptyResponseBody,SessionMessageParameters> messageHeaders)
GetSessionConfigHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,GetSessionConfigResponseBody,SessionMessageParameters> messageHeaders)
OpenSessionHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<OpenSessionRequestBody,OpenSessionResponseBody,EmptyMessageParameters> messageHeaders)
TriggerSessionHeartbeatHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,EmptyResponseBody,SessionMessageParameters> messageHeaders)

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

Constructors in org.apache.flink.table.gateway.rest.handler.statement with parameters of type MessageHeaders

Constructor	Description
CompleteStatementHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<CompleteStatementRequestBody,CompleteStatementResponseBody,SessionMessageParameters> messageHeaders)
ExecuteStatementHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<ExecuteStatementRequestBody,ExecuteStatementResponseBody,SessionMessageParameters> messageHeaders)
FetchResultsHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,FetchResultsResponseBody,FetchResultsMessageParameters> messageHeaders)

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

Constructors in org.apache.flink.table.gateway.rest.handler.util with parameters of type MessageHeaders

Constructor	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 MessageHeaders in org.apache.flink.table.gateway.rest.header

Subinterfaces of MessageHeaders in org.apache.flink.table.gateway.rest.header

Modifier and Type	Interface	Description
interface	SqlGatewayMessageHeaders<R extends RequestBody,P extends ResponseBody,M extends MessageParameters>	This class links RequestBodys to ResponseBodys types and contains meta-data required for their http headers in runtime module.

Uses of MessageHeaders in org.apache.flink.table.gateway.rest.header.materializedtable

Classes in org.apache.flink.table.gateway.rest.header.materializedtable that implement MessageHeaders

Modifier and Type	Class	Description
class	RefreshMaterializedTableHeaders	Message headers for executing a materialized table refresh operation.

Uses of MessageHeaders in org.apache.flink.table.gateway.rest.header.materializedtable.scheduler

Classes in org.apache.flink.table.gateway.rest.header.materializedtable.scheduler that implement MessageHeaders

Modifier and Type	Class	Description
class	AbstractEmbeddedSchedulerWorkflowHeaders	Abstract modify and delete workflow related message headers.
class	CreateEmbeddedSchedulerWorkflowHeaders	Message headers for create workflow in embedded scheduler.
class	DeleteEmbeddedSchedulerWorkflowHeaders	Message headers for delete workflow in embedded scheduler.
class	ResumeEmbeddedSchedulerWorkflowHeaders	Message headers for resume workflow in embedded scheduler.
class	SuspendEmbeddedSchedulerWorkflowHeaders	Message headers for suspend workflow in embedded scheduler.

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

Classes in org.apache.flink.table.gateway.rest.header.operation that implement MessageHeaders

Modifier and Type	Class	Description
class	AbstractOperationHeaders	Abstract operation related message headers.
class	CancelOperationHeaders	Message headers for canceling operation.
class	CloseOperationHeaders	Message headers for closing operation.
class	GetOperationStatusHeaders	Message headers for getting the status of operation.

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

Classes in org.apache.flink.table.gateway.rest.header.session that implement MessageHeaders

Modifier and Type	Class	Description
class	CloseSessionHeaders	Message headers for closing a session.
class	ConfigureSessionHeaders	Message headers for configuring a session.
class	GetSessionConfigHeaders	Message headers for getting session configuration.
class	OpenSessionHeaders	Message headers for opening a session.
class	TriggerSessionHeartbeatHeaders	Message headers for touching the session.

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

Classes in org.apache.flink.table.gateway.rest.header.statement that implement MessageHeaders

Modifier and Type	Class	Description
class	CompleteStatementHeaders	Message headers for completing a statement.
class	ExecuteStatementHeaders	Message headers for executing a statement.
class	FetchResultsHeaders	Message headers for fetching results.

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

Classes in org.apache.flink.table.gateway.rest.header.util that implement MessageHeaders

Modifier and Type	Class	Description
class	GetApiVersionHeaders	Message headers for getting rest api version.
class	GetInfoHeaders	Message headers for getting cluster information.