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