public class JobManagerCustomLogHandler extends AbstractJobManagerFileHandler<FileMessageParameters>
log, MAPPER
leaderRetriever, logger, responseHeaders, timeout
Constructor and Description |
---|
JobManagerCustomLogHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
UntypedResponseMessageHeaders<EmptyRequestBody,FileMessageParameters> messageHeaders,
File logDir) |
Modifier and Type | Method and Description |
---|---|
protected File |
getFile(HandlerRequest<EmptyRequestBody> handlerRequest) |
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
close
public JobManagerCustomLogHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Time timeout, Map<String,String> responseHeaders, UntypedResponseMessageHeaders<EmptyRequestBody,FileMessageParameters> messageHeaders, @Nullable File logDir)
protected File getFile(HandlerRequest<EmptyRequestBody> handlerRequest)
getFile
in class AbstractJobManagerFileHandler<FileMessageParameters>
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.