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<EmptyRequestBody,P,U>,U extends MessageParameters,P extends ResponseBody> |
RestClient.sendRequest(String targetAddress,
int targetPort,
M messageHeaders,
U messageParameters) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<R> |
LegacyRestHandler.handleRequest(HandlerRequest<EmptyRequestBody,M> request,
T gateway) |
protected CompletableFuture<R> |
LegacyRestHandlerAdapter.handleRequest(HandlerRequest<EmptyRequestBody,M> request,
T gateway) |
Constructor and Description |
---|
LegacyRestHandlerAdapter(CompletableFuture<String> localRestAddress,
GatewayRetriever<T> leaderRetriever,
Time timeout,
MessageHeaders<EmptyRequestBody,R,M> messageHeaders,
LegacyRestHandler<T,R,M> legacyRestHandler) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<DashboardConfiguration> |
DashboardConfigHandler.handleRequest(HandlerRequest<EmptyRequestBody,EmptyMessageParameters> request,
DispatcherGateway gateway) |
CompletableFuture<ClusterConfigurationInfo> |
ClusterConfigHandler.handleRequest(HandlerRequest<EmptyRequestBody,EmptyMessageParameters> request,
DispatcherGateway gateway) |
CompletableFuture<MultipleJobsDetails> |
CurrentJobsOverviewHandler.handleRequest(HandlerRequest<EmptyRequestBody,EmptyMessageParameters> request,
DispatcherGateway gateway) |
CompletableFuture<ClusterOverviewWithVersion> |
ClusterOverviewHandler.handleRequest(HandlerRequest<EmptyRequestBody,EmptyMessageParameters> request,
DispatcherGateway gateway) |
Modifier and Type | Method and Description |
---|---|
static EmptyRequestBody |
EmptyRequestBody.getInstance() |
Modifier and Type | Method and Description |
---|---|
Class<EmptyRequestBody> |
ClusterOverviewHeaders.getRequestClass() |
Class<EmptyRequestBody> |
CurrentJobsOverviewHandlerHeaders.getRequestClass() |
Class<EmptyRequestBody> |
ClusterConfigurationInfoHeaders.getRequestClass() |
Class<EmptyRequestBody> |
JobVertexAccumulatorsHeaders.getRequestClass() |
Class<EmptyRequestBody> |
JobExceptionsHeaders.getRequestClass() |
Class<EmptyRequestBody> |
JobTerminationHeaders.getRequestClass() |
Class<EmptyRequestBody> |
JobPlanHeaders.getRequestClass() |
Class<EmptyRequestBody> |
JobConfigHeaders.getRequestClass() |
Class<EmptyRequestBody> |
BlobServerPortHeaders.getRequestClass() |
Class<EmptyRequestBody> |
DashboardConfigurationHeaders.getRequestClass() |
Modifier and Type | Method and Description |
---|---|
Class<EmptyRequestBody> |
CheckpointStatisticDetailsHeaders.getRequestClass() |
Class<EmptyRequestBody> |
CheckpointConfigHeaders.getRequestClass() |
Class<EmptyRequestBody> |
TaskCheckpointStatisticsHeaders.getRequestClass() |
Class<EmptyRequestBody> |
CheckpointingStatisticsHeaders.getRequestClass() |
Modifier and Type | Method and Description |
---|---|
Class<EmptyRequestBody> |
SavepointTriggerHeaders.getRequestClass() |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.