public class SubtasksAllAccumulatorsHandler extends AbstractJobVertexHandler<SubtasksAllAccumulatorsInfo,JobVertexMessageParameters>
log, MAPPER
leaderRetriever, logger, responseHeaders, timeout
Constructor and Description |
---|
SubtasksAllAccumulatorsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
MessageHeaders<EmptyRequestBody,SubtasksAllAccumulatorsInfo,JobVertexMessageParameters> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor) |
Modifier and Type | Method and Description |
---|---|
protected SubtasksAllAccumulatorsInfo |
handleRequest(HandlerRequest<EmptyRequestBody,JobVertexMessageParameters> request,
AccessExecutionJobVertex jobVertex)
Called for each request after the corresponding
AccessExecutionJobVertex has been
retrieved from the AccessExecutionGraph . |
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 SubtasksAllAccumulatorsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,SubtasksAllAccumulatorsInfo,JobVertexMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
protected SubtasksAllAccumulatorsInfo handleRequest(HandlerRequest<EmptyRequestBody,JobVertexMessageParameters> request, AccessExecutionJobVertex jobVertex) throws RestHandlerException
AbstractJobVertexHandler
AccessExecutionJobVertex
has been
retrieved from the AccessExecutionGraph
.handleRequest
in class AbstractJobVertexHandler<SubtasksAllAccumulatorsInfo,JobVertexMessageParameters>
request
- the requestjobVertex
- the execution job vertexRestHandlerException
- if the handler could not process the requestCopyright © 2014–2021 The Apache Software Foundation. All rights reserved.