public class SubtaskCurrentAttemptDetailsHandler extends AbstractSubtaskHandler<SubtaskExecutionAttemptDetailsInfo,SubtaskMessageParameters>
log, MAPPER
leaderRetriever, logger, responseHeaders, timeout
Constructor and Description |
---|
SubtaskCurrentAttemptDetailsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
MessageHeaders<EmptyRequestBody,SubtaskExecutionAttemptDetailsInfo,SubtaskMessageParameters> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor,
MetricFetcher metricFetcher) |
Modifier and Type | Method and Description |
---|---|
protected SubtaskExecutionAttemptDetailsInfo |
handleRequest(HandlerRequest<EmptyRequestBody> request,
AccessExecutionVertex executionVertex)
Called for each request after the corresponding
AccessExecutionVertex has been
retrieved from the AccessExecutionJobVertex . |
handleRequest
handleRequest
handleRequest
handleRequest
getMessageHeaders, respondToRequest
closeAsync, closeHandlerAsync, respondAsLeader
channelRead0
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 SubtaskCurrentAttemptDetailsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,SubtaskExecutionAttemptDetailsInfo,SubtaskMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor, MetricFetcher metricFetcher)
protected SubtaskExecutionAttemptDetailsInfo handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionVertex executionVertex) throws RestHandlerException
AbstractSubtaskHandler
AccessExecutionVertex
has been
retrieved from the AccessExecutionJobVertex
.handleRequest
in class AbstractSubtaskHandler<SubtaskExecutionAttemptDetailsInfo,SubtaskMessageParameters>
request
- the requestexecutionVertex
- the execution vertexRestHandlerException
- the rest handler exceptionCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.