public class JobVertexAccumulatorsHandler extends AbstractJobVertexHandler<JobVertexAccumulatorsInfo,JobVertexMessageParameters>
log, MAPPER
leaderRetriever, localAddressFuture, logger, responseHeaders, timeout
Constructor and Description |
---|
JobVertexAccumulatorsHandler(CompletableFuture<String> localRestAddress,
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,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
handlerAdded, handlerRemoved, isSharable
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
public JobVertexAccumulatorsHandler(CompletableFuture<String> localRestAddress, GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobVertexAccumulatorsInfo,JobVertexMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
protected JobVertexAccumulatorsInfo handleRequest(HandlerRequest<EmptyRequestBody,JobVertexMessageParameters> 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–2019 The Apache Software Foundation. All rights reserved.