AbstractAggregatingMetricsHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
AbstractAggregatedMetricsHeaders<P> messageHeaders,
Executor executor,
MetricFetcher<?> fetcher) |
AbstractMetricsHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> headers,
MessageHeaders<EmptyRequestBody,MetricCollectionResponseBody,M> messageHeaders,
MetricFetcher metricFetcher) |
AggregatingJobsMetricsHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
Executor executor,
MetricFetcher<?> fetcher) |
AggregatingSubtasksMetricsHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
Executor executor,
MetricFetcher<?> fetcher) |
AggregatingTaskManagersMetricsHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
Executor executor,
MetricFetcher<?> fetcher) |
JobManagerMetricsHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> headers,
MetricFetcher metricFetcher) |
JobMetricsHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> headers,
MetricFetcher metricFetcher) |
JobVertexMetricsHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> headers,
MetricFetcher metricFetcher)
Deprecated.
|
SubtaskMetricsHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> headers,
MetricFetcher metricFetcher) |
TaskManagerMetricsHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> headers,
MetricFetcher metricFetcher) |