Modifier and Type | Class and 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.
|
Modifier and Type | Method and Description |
---|---|
protected List<Tuple2<RestHandlerSpecification,org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler>> |
DispatcherRestEndpoint.initializeHandlers(CompletableFuture<String> localAddressFuture) |
protected Collection<Tuple2<RestHandlerSpecification,org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler>> |
DispatcherRestEndpoint.initializeWebSubmissionHandlers(CompletableFuture<String> localAddressFuture) |
Modifier and Type | Method and Description |
---|---|
protected abstract List<Tuple2<RestHandlerSpecification,org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler>> |
RestServerEndpoint.initializeHandlers(CompletableFuture<String> localAddressFuture)
This method is called at the beginning of
RestServerEndpoint.start() to setup all handlers that the
REST server endpoint implementation requires. |
Modifier and Type | Method and Description |
---|---|
int |
RestServerEndpoint.RestHandlerUrlComparator.compare(Tuple2<RestHandlerSpecification,org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler> o1,
Tuple2<RestHandlerSpecification,org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler> o2) |
int |
RestServerEndpoint.RestHandlerUrlComparator.compare(Tuple2<RestHandlerSpecification,org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler> o1,
Tuple2<RestHandlerSpecification,org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler> o2) |
Modifier and Type | Class and 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.
|
Modifier and Type | Class and 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.
|
Modifier and Type | Class and Description |
---|---|
class |
WebContentHandlerSpecification
Rest handler specification for the web content handler.
|
Modifier and Type | Interface and Description |
---|---|
interface |
MessageHeaders<R extends RequestBody,P extends ResponseBody,M extends MessageParameters>
This class links
RequestBody s to ResponseBody s types and contains meta-data
required for their http headers. |
interface |
RuntimeMessageHeaders<R extends RequestBody,P extends ResponseBody,M extends MessageParameters>
This class links
RequestBody s to ResponseBody s types and contains meta-data
required for their http headers in runtime module. |
interface |
RuntimeUntypedResponseMessageHeaders<R extends RequestBody,M extends MessageParameters>
Message headers for a web handler request that belongs to runtime module.
|
interface |
UntypedResponseMessageHeaders<R extends RequestBody,M extends MessageParameters>
Message headers for a web handler request.
|
Modifier and Type | Class and 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 . |
Modifier and Type | Class and Description |
---|---|
class |
JobManagerCustomLogHeaders
Headers for the
JobManagerCustomLogHandler . |
class |
JobManagerLogFileHeader
Headers for the
JobManagerLogFileHandler . |
class |
JobManagerLogListHeaders
Headers for the
JobManagerLogListHandler . |
class |
JobManagerProfilingFileHeaders
Headers for the
JobManagerProfilingFileHandler . |
class |
JobManagerProfilingHeaders
Headers for the
JobManagerProfilingHandler . |
class |
JobManagerProfilingListHeaders
Headers for the
JobManagerProfilingHandler . |
class |
JobManagerStdoutFileHeader
Headers for the
JobManagerStdoutFileHandler . |
class |
JobManagerThreadDumpHeaders
Headers for the
JobManagerThreadDumpHandler . |
class |
ShutdownHeaders
Message headers for
ShutdownHandler . |
Modifier and Type | Class and 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.
|
Modifier and Type | Class and Description |
---|---|
class |
ClientCoordinationHeaders
Message headers for the
ClientCoordinationHandler . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractAggregatedMetricsHeaders<P extends AbstractAggregatedMetricsParameters<?>>
Based
MessageHeaders class for aggregating metrics. |
class |
AbstractMetricsHeaders<M extends MessageParameters>
|
class |
AggregatedJobMetricsHeaders
Headers for aggregating job metrics.
|
class |
AggregatedSubtaskMetricsHeaders
Headers for aggregating subtask metrics.
|
class |
AggregatedTaskManagerMetricsHeaders
Headers for aggregating task manager metrics.
|
class |
JobManagerMetricsHeaders
|
class |
JobManagerOperatorMetricsHeaders
|
class |
JobMetricsHeaders
|
class |
JobVertexMetricsHeaders
|
class |
JobVertexWatermarksHeaders
MessageHeaders for retrieving watermarks. |
class |
SubtaskMetricsHeaders
|
class |
TaskManagerMetricsHeaders
|
Modifier and Type | Class and 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.
|
Modifier and Type | Class and Description |
---|---|
class |
StopWithSavepointTriggerHeaders
These headers define the protocol for triggering a "stop" action.
|
Modifier and Type | Class and Description |
---|---|
class |
TaskManagerCustomLogHeaders
Headers for the
TaskManagerCustomLogHandler . |
class |
TaskManagerDetailsHeaders
Headers for the
TaskManagerDetailsHandler which serves the TaskManager details. |
class |
TaskManagerLogFileHeaders
Headers for the
TaskManagerLogFileHandler . |
class |
TaskManagerLogsHeaders
Headers for the
TaskManagerLogListHandler . |
class |
TaskManagerProfilingFileHeaders
Headers for the
TaskManagerProfilingFileHandler . |
class |
TaskManagerProfilingHeaders
Headers for the
TaskManagerProfilingHandler . |
class |
TaskManagerProfilingListHeaders
Headers for the
TaskManagerProfilingListHandler . |
class |
TaskManagersHeaders
Message headers for the
TaskManagersHandler . |
class |
TaskManagerStdoutFileHeaders
Headers for the
TaskManagerStdoutFileHandler . |
class |
TaskManagerThreadDumpHeaders
Headers for the
TaskManagerThreadDumpHandler . |
Modifier and Type | Method and Description |
---|---|
Collection<Tuple2<RestHandlerSpecification,org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler>> |
WebSubmissionExtension.getHandlers() |
Collection<Tuple2<RestHandlerSpecification,org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler>> |
WebMonitorExtension.getHandlers()
Gets the collection of extension handlers to register at the
WebMonitorEndpoint . |
Collection<Tuple2<RestHandlerSpecification,org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler>> |
WebMonitorExtension.EmptyWebMonitorExtension.getHandlers() |
protected List<Tuple2<RestHandlerSpecification,org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler>> |
WebMonitorEndpoint.initializeHandlers(CompletableFuture<String> localAddressFuture) |
protected Collection<Tuple2<RestHandlerSpecification,org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler>> |
WebMonitorEndpoint.initializeWebSubmissionHandlers(CompletableFuture<String> localAddressFuture) |
Modifier and Type | Class and 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
|
class |
JarUploadHeaders
MessageHeaders for uploading jars. |
Modifier and Type | Method and Description |
---|---|
protected List<Tuple2<RestHandlerSpecification,org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler>> |
SqlGatewayRestEndpoint.initializeHandlers(CompletableFuture<String> localAddressFuture) |
Modifier and Type | Method and Description |
---|---|
protected void |
SqlGatewayRestEndpoint.addOperationRelatedHandlers(List<Tuple2<RestHandlerSpecification,org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler>> handlers) |
protected void |
SqlGatewayRestEndpoint.addUtilRelatedHandlers(List<Tuple2<RestHandlerSpecification,org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler>> handlers) |
Modifier and Type | Interface and Description |
---|---|
interface |
SqlGatewayMessageHeaders<R extends RequestBody,P extends ResponseBody,M extends MessageParameters>
This class links
RequestBody s to ResponseBody s types and contains meta-data
required for their http headers in runtime module. |
Modifier and Type | Class and Description |
---|---|
class |
RefreshMaterializedTableHeaders
Message headers for executing a materialized table refresh operation.
|
Modifier and Type | Class and 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.
|
Modifier and Type | Class and 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.
|
Modifier and Type | Class and 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.
|
Modifier and Type | Class and Description |
---|---|
class |
CompleteStatementHeaders
Message headers for completing a statement.
|
class |
ExecuteStatementHeaders
Message headers for executing a statement.
|
class |
FetchResultsHeaders
Message headers for fetching results.
|
Modifier and Type | Class and Description |
---|---|
class |
GetApiVersionHeaders
Message headers for getting rest api version.
|
class |
GetInfoHeaders
Message headers for getting cluster information.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.