Modifier and Type | Method and Description |
---|---|
<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) |
<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,
Collection<FileUpload> fileUploads) |
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,
Map<String,String> responseHeaders,
MessageHeaders<R,P,M> messageHeaders) |
LegacyRestHandlerAdapter(CompletableFuture<String> localRestAddress,
GatewayRetriever<T> leaderRetriever,
Time timeout,
Map<String,String> headers,
MessageHeaders<EmptyRequestBody,R,M> messageHeaders,
LegacyRestHandler<T,R,M> legacyRestHandler) |
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.
|
Constructor and Description |
---|
StatusHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<? extends T> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
MessageHeaders<EmptyRequestBody,AsynchronousOperationResult<V>,M> messageHeaders) |
TriggerHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<? extends T> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
MessageHeaders<B,TriggerResponse,M> messageHeaders) |
Constructor and Description |
---|
AbstractMetricsHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> headers,
MessageHeaders<EmptyRequestBody,MetricCollectionResponseBody,M> messageHeaders,
MetricFetcher metricFetcher) |
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.
|
Constructor and Description |
---|
TaskManagerDetailsHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
MessageHeaders<EmptyRequestBody,TaskManagerDetailsInfo,TaskManagerMessageParameters> messageHeaders,
GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever,
MetricFetcher metricFetcher) |
TaskManagersHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
MessageHeaders<EmptyRequestBody,TaskManagersInfo,EmptyMessageParameters> messageHeaders,
GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever) |
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 |
ShutdownHeaders
Message headers for
ShutdownHandler . |
Modifier and Type | Class and Description |
---|---|
class |
JobDetailsHeaders
Message headers for the
JobDetailsHandler . |
class |
JobExecutionResultHeaders
|
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 |
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 |
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 |
TaskManagerDetailsHeaders
Headers for the
TaskManagerDetailsHandler which serves the TaskManager details. |
class |
TaskManagersHeaders
Message headers for the
TaskManagersHandler . |
Modifier and Type | Class and Description |
---|---|
class |
JarDeleteHeaders
Message headers for
JarDeleteHandler . |
class |
JarListHeaders
Message headers for the
JarListHandler . |
class |
JarPlanHeaders
Message headers for
JarPlanHandler . |
class |
JarRunHeaders
|
class |
JarUploadHeaders
MessageHeaders for uploading jars. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.