public class JobExceptionsHandler extends AbstractExecutionGraphHandler<JobExceptionsInfo,JobMessageParameters>
log
leaderRetriever, localAddressFuture, logger, timeout
Constructor and Description |
---|
JobExceptionsHandler(CompletableFuture<String> localRestAddress,
GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
MessageHeaders<EmptyRequestBody,JobExceptionsInfo,JobMessageParameters> messageHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor) |
Modifier and Type | Method and Description |
---|---|
protected JobExceptionsInfo |
handleRequest(HandlerRequest<EmptyRequestBody,JobMessageParameters> 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
public JobExceptionsHandler(CompletableFuture<String> localRestAddress, GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, MessageHeaders<EmptyRequestBody,JobExceptionsInfo,JobMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor)
protected JobExceptionsInfo handleRequest(HandlerRequest<EmptyRequestBody,JobMessageParameters> request, AccessExecutionGraph executionGraph)
AbstractExecutionGraphHandler
AccessExecutionGraph
has been retrieved from the
ExecutionGraphCache
.handleRequest
in class AbstractExecutionGraphHandler<JobExceptionsInfo,JobMessageParameters>
request
- for further informationexecutionGraph
- for which the handler was calledCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.