Modifier and Type | Method and Description |
---|---|
<M extends MessageHeaders<EmptyRequestBody,P,EmptyMessageParameters>,P extends ResponseBody> |
RestClient.sendRequest(String targetAddress,
int targetPort,
M messageHeaders) |
<M extends MessageHeaders<R,P,EmptyMessageParameters>,R extends RequestBody,P extends ResponseBody> |
RestClient.sendRequest(String targetAddress,
int targetPort,
M messageHeaders,
R request) |
<M extends MessageHeaders<EmptyRequestBody,P,U>,U extends MessageParameters,P extends ResponseBody> |
RestClient.sendRequest(String targetAddress,
int targetPort,
M messageHeaders,
U messageParameters) |
<M extends MessageHeaders<R,P,U>,U extends MessageParameters,R extends RequestBody,P extends ResponseBody> |
RestClient.sendRequest(String targetAddress,
int targetPort,
M messageHeaders,
U messageParameters,
R request) |
Modifier and Type | Method and Description |
---|---|
MessageHeaders<R,P,M> |
AbstractRestHandler.getMessageHeaders() |
Constructor and Description |
---|
AbstractRestHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<? extends T> leaderRetriever,
Time timeout,
MessageHeaders<R,P,M> messageHeaders) |
LegacyRestHandlerAdapter(CompletableFuture<String> localRestAddress,
GatewayRetriever<T> leaderRetriever,
Time timeout,
MessageHeaders<EmptyRequestBody,R,M> messageHeaders,
LegacyRestHandler<T,R,M> legacyRestHandler) |
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.