R
- type of the responsepublic abstract class AbstractCheckpointHandler<R extends ResponseBody,M extends CheckpointMessageParameters> extends AbstractExecutionGraphHandler<R,M>
log
leaderRetriever, localAddressFuture, logger, timeout
Modifier | Constructor and Description |
---|---|
protected |
AbstractCheckpointHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
MessageHeaders<EmptyRequestBody,R,M> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor,
CheckpointStatsCache checkpointStatsCache) |
Modifier and Type | Method and Description |
---|---|
protected abstract R |
handleCheckpointRequest(HandlerRequest<EmptyRequestBody,M> request,
AbstractCheckpointStats checkpointStats)
Called for each request with the corresponding
AbstractCheckpointStats instance. |
protected R |
handleRequest(HandlerRequest<EmptyRequestBody,M> request,
AccessExecutionGraph executionGraph)
Called for each request after the corresponding
AccessExecutionGraph has been retrieved from the
ExecutionGraphCache . |
handleRequest
getMessageHeaders, respondAsLeader
channelRead0
acceptInboundMessage, channelRead
channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
handlerAdded, handlerRemoved, isSharable
protected AbstractCheckpointHandler(CompletableFuture<String> localRestAddress, GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, MessageHeaders<EmptyRequestBody,R,M> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor, CheckpointStatsCache checkpointStatsCache)
protected R handleRequest(HandlerRequest<EmptyRequestBody,M> request, AccessExecutionGraph executionGraph) throws RestHandlerException
AbstractExecutionGraphHandler
AccessExecutionGraph
has been retrieved from the
ExecutionGraphCache
.handleRequest
in class AbstractExecutionGraphHandler<R extends ResponseBody,M extends CheckpointMessageParameters>
request
- for further informationexecutionGraph
- for which the handler was calledRestHandlerException
- if the handler could not process the requestprotected abstract R handleCheckpointRequest(HandlerRequest<EmptyRequestBody,M> request, AbstractCheckpointStats checkpointStats) throws RestHandlerException
AbstractCheckpointStats
instance.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.