public class SubtaskExecutionAttemptAccumulatorsHandler extends AbstractSubtaskAttemptHandler<SubtaskExecutionAttemptAccumulatorsInfo,SubtaskAttemptMessageParameters> implements JsonArchivist
log, MAPPER
leaderRetriever, logger, responseHeaders, timeout
Constructor and Description |
---|
SubtaskExecutionAttemptAccumulatorsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
MessageHeaders<EmptyRequestBody,SubtaskExecutionAttemptAccumulatorsInfo,SubtaskAttemptMessageParameters> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor)
Instantiates a new Abstract job vertex handler.
|
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 SubtaskExecutionAttemptAccumulatorsInfo |
handleRequest(HandlerRequest<EmptyRequestBody,SubtaskAttemptMessageParameters> request,
AccessExecution execution)
Called for each request after the corresponding
AccessExecution has been retrieved from the
AccessExecutionVertex . |
handleRequest
handleRequest
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 SubtaskExecutionAttemptAccumulatorsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,SubtaskExecutionAttemptAccumulatorsInfo,SubtaskAttemptMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
leaderRetriever
- the leader retrievertimeout
- the timeoutresponseHeaders
- the response headersmessageHeaders
- the message headersexecutionGraphCache
- the execution graph cacheexecutor
- the executorprotected SubtaskExecutionAttemptAccumulatorsInfo handleRequest(HandlerRequest<EmptyRequestBody,SubtaskAttemptMessageParameters> request, AccessExecution execution) throws RestHandlerException
AbstractSubtaskAttemptHandler
AccessExecution
has been retrieved from the
AccessExecutionVertex
.handleRequest
in class AbstractSubtaskAttemptHandler<SubtaskExecutionAttemptAccumulatorsInfo,SubtaskAttemptMessageParameters>
request
- the requestexecution
- the executionRestHandlerException
- the rest handler exceptionpublic 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–2020 The Apache Software Foundation. All rights reserved.