SubtaskMetricsHandler
and is only kept for
backwards-compatibility.public class JobVertexMetricsHandler extends AbstractMetricsHandler<JobVertexMetricsMessageParameters>
JobID
and JobVertexID
.log, MAPPER
leaderRetriever, logger, responseHeaders, timeout
Constructor and Description |
---|
JobVertexMetricsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> headers,
MetricFetcher metricFetcher)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected MetricStore.ComponentMetricStore |
getComponentMetricStore(HandlerRequest<EmptyRequestBody> request,
MetricStore metricStore)
Deprecated.
Returns the
MetricStore.ComponentMetricStore that should be queried for metrics. |
handleRequest
getMessageHeaders, respondToRequest
closeAsync, closeHandlerAsync, respondAsLeader
channelRead0, getTimeout
acceptInboundMessage, channelRead
channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
ensureNotSharable, handlerAdded, handlerRemoved, isSharable
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
public JobVertexMetricsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> headers, MetricFetcher metricFetcher)
protected MetricStore.ComponentMetricStore getComponentMetricStore(HandlerRequest<EmptyRequestBody> request, MetricStore metricStore)
AbstractMetricsHandler
MetricStore.ComponentMetricStore
that should be queried for metrics.getComponentMetricStore
in class AbstractMetricsHandler<JobVertexMetricsMessageParameters>
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.