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