public class CheckpointStatisticDetailsHandler extends AbstractCheckpointHandler<CheckpointStatistics,CheckpointMessageParameters>
log
leaderRetriever, localAddressFuture, logger, timeout
Constructor and Description |
---|
CheckpointStatisticDetailsHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
MessageHeaders<EmptyRequestBody,CheckpointStatistics,CheckpointMessageParameters> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor,
CheckpointStatsCache checkpointStatsCache) |
Modifier and Type | Method and Description |
---|---|
protected CheckpointStatistics |
handleCheckpointRequest(HandlerRequest<EmptyRequestBody,CheckpointMessageParameters> ignored,
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 CheckpointStatisticDetailsHandler(CompletableFuture<String> localRestAddress, GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, MessageHeaders<EmptyRequestBody,CheckpointStatistics,CheckpointMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor, CheckpointStatsCache checkpointStatsCache)
protected CheckpointStatistics handleCheckpointRequest(HandlerRequest<EmptyRequestBody,CheckpointMessageParameters> ignored, AbstractCheckpointStats checkpointStats)
AbstractCheckpointHandler
AbstractCheckpointStats
instance.handleCheckpointRequest
in class AbstractCheckpointHandler<CheckpointStatistics,CheckpointMessageParameters>
ignored
- for further informationcheckpointStats
- for which the handler is calledCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.