public class JobAccumulatorsHandler extends AbstractExecutionGraphHandler<JobAccumulatorsInfo,JobAccumulatorsMessageParameters> implements JsonArchivist
log, MAPPER
leaderRetriever, logger, responseHeaders, timeout
Constructor and Description |
---|
JobAccumulatorsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
MessageHeaders<EmptyRequestBody,JobAccumulatorsInfo,JobAccumulatorsMessageParameters> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor) |
Modifier and Type | Method and Description |
---|---|
Collection<ArchivedJson> |
archiveJsonWithPath(AccessExecutionGraph graph)
Returns a
Collection of ArchivedJson s containing JSON responses and their
respective REST URL for a given job. |
protected JobAccumulatorsInfo |
handleRequest(HandlerRequest<EmptyRequestBody,JobAccumulatorsMessageParameters> request,
AccessExecutionGraph graph)
Called for each request after the corresponding
AccessExecutionGraph has been
retrieved from the ExecutionGraphCache . |
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 JobAccumulatorsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,JobAccumulatorsInfo,JobAccumulatorsMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
protected JobAccumulatorsInfo handleRequest(HandlerRequest<EmptyRequestBody,JobAccumulatorsMessageParameters> request, AccessExecutionGraph graph) throws RestHandlerException
AbstractExecutionGraphHandler
AccessExecutionGraph
has been
retrieved from the ExecutionGraphCache
.handleRequest
in class AbstractExecutionGraphHandler<JobAccumulatorsInfo,JobAccumulatorsMessageParameters>
request
- for further informationgraph
- for which the handler was calledRestHandlerException
- if the handler could not process the requestpublic Collection<ArchivedJson> archiveJsonWithPath(AccessExecutionGraph graph) throws IOException
JsonArchivist
Collection
of ArchivedJson
s containing JSON responses and their
respective REST URL for a given job.
The collection should contain one entry for every response that could be generated for the given job, for example one entry for each task. The REST URLs should be unique and must not contain placeholders.
archiveJsonWithPath
in interface JsonArchivist
graph
- AccessExecutionGraph for which the responses should be generatedIOException
- thrown if the JSON generation failsCopyright © 2014–2021 The Apache Software Foundation. All rights reserved.