public class AggregatingTaskManagersMetricsHandler extends AbstractJsonRequestHandler
Specific taskmanagers can be selected for aggregation by specifying a comma-separated list of taskmanager IDs.
/metrics?get=X,Y&taskmanagers=A,B
Modifier and Type | Field and Description |
---|---|
protected org.slf4j.Logger |
log |
executor
Constructor and Description |
---|
AggregatingTaskManagersMetricsHandler(Executor executor,
MetricFetcher fetcher) |
Modifier and Type | Method and Description |
---|---|
String[] |
getPaths()
Returns an array of REST URL's under which this handler can be registered.
|
protected Collection<? extends MetricStore.ComponentMetricStore> |
getStores(MetricStore store,
Map<String,String> pathParameters,
Map<String,String> queryParameters) |
CompletableFuture<String> |
handleJsonRequest(Map<String,String> pathParams,
Map<String,String> queryParams,
JobManagerGateway jobManagerGateway)
Core method that handles the request and generates the response.
|
handleRequest
public AggregatingTaskManagersMetricsHandler(Executor executor, MetricFetcher fetcher)
protected Collection<? extends MetricStore.ComponentMetricStore> getStores(MetricStore store, Map<String,String> pathParameters, Map<String,String> queryParameters)
public String[] getPaths()
RequestHandler
public CompletableFuture<String> handleJsonRequest(Map<String,String> pathParams, Map<String,String> queryParams, JobManagerGateway jobManagerGateway)
AbstractJsonRequestHandler
handleJsonRequest
in class AbstractJsonRequestHandler
pathParams
- The map of REST path parameters, decoded by the router.queryParams
- The map of query parameters.jobManagerGateway
- to communicate with the JobManager.Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.