public class TaskCheckpointStatisticDetailsHandler extends AbstractCheckpointHandler<TaskCheckpointStatisticsWithSubtaskDetails,TaskCheckpointMessageParameters>
log
leaderRetriever, localAddressFuture, logger, timeout
Constructor and Description |
---|
TaskCheckpointStatisticDetailsHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
MessageHeaders<EmptyRequestBody,TaskCheckpointStatisticsWithSubtaskDetails,TaskCheckpointMessageParameters> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor,
CheckpointStatsCache checkpointStatsCache) |
Modifier and Type | Method and Description |
---|---|
protected TaskCheckpointStatisticsWithSubtaskDetails |
handleCheckpointRequest(HandlerRequest<EmptyRequestBody,TaskCheckpointMessageParameters> request,
AbstractCheckpointStats checkpointStats)
Called for each request with the corresponding
AbstractCheckpointStats instance. |
handleRequest
handleRequest
getMessageHeaders, respondAsLeader
channelRead0
acceptInboundMessage, channelRead
channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
handlerAdded, handlerRemoved, isSharable
public TaskCheckpointStatisticDetailsHandler(CompletableFuture<String> localRestAddress, GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, MessageHeaders<EmptyRequestBody,TaskCheckpointStatisticsWithSubtaskDetails,TaskCheckpointMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor, CheckpointStatsCache checkpointStatsCache)
protected TaskCheckpointStatisticsWithSubtaskDetails handleCheckpointRequest(HandlerRequest<EmptyRequestBody,TaskCheckpointMessageParameters> 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 requestCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.