public class TaskManagerCustomLogHandler extends AbstractTaskManagerFileHandler<TaskManagerFileMessageParameters>
TaskExecutor
.log, MAPPER
leaderRetriever, logger, responseHeaders, timeout
Constructor and Description |
---|
TaskManagerCustomLogHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
UntypedResponseMessageHeaders<EmptyRequestBody,TaskManagerFileMessageParameters> untypedResponseMessageHeaders,
GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever,
TransientBlobService transientBlobService,
Time cacheEntryDuration) |
Modifier and Type | Method and Description |
---|---|
protected String |
getFileName(HandlerRequest<EmptyRequestBody,TaskManagerFileMessageParameters> handlerRequest) |
protected CompletableFuture<TransientBlobKey> |
requestFileUpload(ResourceManagerGateway resourceManagerGateway,
Tuple2<ResourceID,String> taskManagerIdAndFileName) |
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 TaskManagerCustomLogHandler(@Nonnull GatewayRetriever<? extends RestfulGateway> leaderRetriever, @Nonnull Time timeout, @Nonnull Map<String,String> responseHeaders, @Nonnull UntypedResponseMessageHeaders<EmptyRequestBody,TaskManagerFileMessageParameters> untypedResponseMessageHeaders, @Nonnull GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, @Nonnull TransientBlobService transientBlobService, @Nonnull Time cacheEntryDuration)
protected CompletableFuture<TransientBlobKey> requestFileUpload(ResourceManagerGateway resourceManagerGateway, Tuple2<ResourceID,String> taskManagerIdAndFileName)
requestFileUpload
in class AbstractTaskManagerFileHandler<TaskManagerFileMessageParameters>
protected String getFileName(HandlerRequest<EmptyRequestBody,TaskManagerFileMessageParameters> handlerRequest)
getFileName
in class AbstractTaskManagerFileHandler<TaskManagerFileMessageParameters>
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.