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 |
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 |
JobDetailsHeaders
Message headers for the
JobDetailsHandler . |
class |
JobExecutionResultHeaders
|
class |
JobManagerJobConfigurationHeaders
Message headers for the
JobManagerJobConfigurationHandler . |
class |
JobManagerJobEnvironmentHeaders
Message headers for the
JobManagerJobEnvironmentHandler . |
class |
JobStatusInfoHeaders
|
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 . |
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 |
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 |
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 |
AbstactOperationHeaders
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 |
GetSessionConfigHeaders
Message headers for closing a session.
|
class |
OpenSessionHeaders
Message headers for opening a session.
|
class |
TriggerSessionHeartbeatHeaders
Message headers for closing a session.
|
Modifier and Type | Class and Description |
---|---|
class |
ExecuteStatementHeaders
Message headers for execute 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–2022 The Apache Software Foundation. All rights reserved.