public class TaskCheckpointStatisticDetailsHandler extends AbstractCheckpointHandler<TaskCheckpointStatisticsWithSubtaskDetails,TaskCheckpointMessageParameters> implements OnlyExecutionGraphJsonArchivist
log, MAPPER
leaderRetriever, logger, responseHeaders, timeout
Constructor and Description |
---|
TaskCheckpointStatisticDetailsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
MessageHeaders<EmptyRequestBody,TaskCheckpointStatisticsWithSubtaskDetails,TaskCheckpointMessageParameters> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor,
CheckpointStatsCache checkpointStatsCache) |
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 TaskCheckpointStatisticsWithSubtaskDetails |
handleCheckpointRequest(HandlerRequest<EmptyRequestBody> request,
AbstractCheckpointStats checkpointStats)
Called for each request with the corresponding
AbstractCheckpointStats instance. |
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
archiveJsonWithPath
close
public TaskCheckpointStatisticDetailsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,TaskCheckpointStatisticsWithSubtaskDetails,TaskCheckpointMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor, CheckpointStatsCache checkpointStatsCache)
protected TaskCheckpointStatisticsWithSubtaskDetails handleCheckpointRequest(HandlerRequest<EmptyRequestBody> request, AbstractCheckpointStats checkpointStats) throws RestHandlerException
AbstractCheckpointHandler
AbstractCheckpointStats
instance.handleCheckpointRequest
in class AbstractCheckpointHandler<TaskCheckpointStatisticsWithSubtaskDetails,TaskCheckpointMessageParameters>
request
- for further informationcheckpointStats
- for which the handler is calledRestHandlerException
- if the handler could not handle the requestpublic Collection<ArchivedJson> archiveJsonWithPath(AccessExecutionGraph graph) throws IOException
OnlyExecutionGraphJsonArchivist
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 OnlyExecutionGraphJsonArchivist
graph
- AccessExecutionGraph for which the responses should be generatedIOException
- thrown if the JSON generation failsCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.