Modifier and Type | Method and Description |
---|---|
protected Collection<Tuple2<RestHandlerSpecification,org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler>> |
DispatcherRestEndpoint.initializeHandlers(CompletableFuture<String> restAddressFuture) |
Modifier and Type | Method and Description |
---|---|
protected abstract Collection<Tuple2<RestHandlerSpecification,org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler>> |
RestServerEndpoint.initializeHandlers(CompletableFuture<String> restAddressFuture)
This method is called at the beginning of
RestServerEndpoint.start() to setup all handlers that the REST server endpoint
implementation requires. |
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. |
Modifier and Type | Class and Description |
---|---|
class |
BlobServerPortHeaders
These headers define the protocol for querying the port of the blob server.
|
class |
ClusterConfigurationInfoHeaders
Message headers for the
ClusterConfigHandler . |
class |
ClusterOverviewHeaders
Message headers for the
ClusterOverviewHandler . |
class |
CurrentJobsOverviewHandlerHeaders
Message headers for
CurrentJobsOverviewHandler . |
class |
DashboardConfigurationHeaders
Message headers for the
DashboardConfigHandler . |
class |
JobConfigHeaders
Message headers for the
JobConfigHandler . |
class |
JobExceptionsHeaders
Message headers for the
JobExceptionsHandler . |
class |
JobPlanHeaders
Message headers for the
JobPlanHandler . |
class |
JobTerminationHeaders
Message headers for the
JobCancellationHandler . |
class |
JobVertexAccumulatorsHeaders
Message headers for the
JobVertexAccumulatorsHandler . |
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 |
TaskCheckpointStatisticsHeaders
Headers for the
TaskCheckpointStatisticDetailsHandler . |
Modifier and Type | Class and Description |
---|---|
class |
JobSubmitHeaders
These headers define the protocol for submitting a job to a flink cluster.
|
Modifier and Type | Class and Description |
---|---|
class |
SavepointTriggerHeaders
These headers define the protocol for triggering a savepoint.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.