R
- the response typeM
- the message parameters typepublic abstract class AbstractJobVertexHandler<R extends ResponseBody,M extends JobVertexMessageParameters> extends AbstractAccessExecutionGraphHandler<R,M>
JobVertexIdPathParameter.KEY
" parameter) in a specific job, defined via (defined via the
"JobIDPathParameter.KEY
" parameter).log, MAPPER
leaderRetriever, logger, responseHeaders, timeout
Modifier | Constructor and Description |
---|---|
protected |
AbstractJobVertexHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
MessageHeaders<EmptyRequestBody,R,M> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor)
Instantiates a new Abstract job vertex handler.
|
Modifier and Type | Method and Description |
---|---|
protected R |
handleRequest(HandlerRequest<EmptyRequestBody> request,
AccessExecutionGraph executionGraph) |
protected abstract R |
handleRequest(HandlerRequest<EmptyRequestBody> 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, 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
protected AbstractJobVertexHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,R,M> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
leaderRetriever
- the leader retrievertimeout
- the timeoutresponseHeaders
- the response headersmessageHeaders
- the message headersexecutionGraphCache
- the execution graph cacheexecutor
- the executorprotected R handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionGraph executionGraph) throws RestHandlerException
handleRequest
in class AbstractAccessExecutionGraphHandler<R extends ResponseBody,M extends JobVertexMessageParameters>
RestHandlerException
protected abstract R handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionJobVertex jobVertex) throws RestHandlerException
AccessExecutionJobVertex
has been
retrieved from the AccessExecutionGraph
.request
- the requestjobVertex
- the execution job vertexRestHandlerException
- if the handler could not process the requestCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.