Class SubtaskCurrentAttemptDetailsHandler
- java.lang.Object
-
- org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerAdapter
-
- org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandlerAdapter
-
- org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler<RoutedRequest>
-
- org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler<T>
-
- org.apache.flink.runtime.rest.handler.AbstractHandler<T,R,M>
-
- org.apache.flink.runtime.rest.handler.AbstractRestHandler<RestfulGateway,EmptyRequestBody,R,M>
-
- org.apache.flink.runtime.rest.handler.job.AbstractExecutionGraphHandler<R,M>
-
- org.apache.flink.runtime.rest.handler.job.AbstractAccessExecutionGraphHandler<R,M>
-
- org.apache.flink.runtime.rest.handler.job.AbstractJobVertexHandler<R,M>
-
- org.apache.flink.runtime.rest.handler.job.AbstractSubtaskHandler<SubtaskExecutionAttemptDetailsInfo,SubtaskMessageParameters>
-
- org.apache.flink.runtime.rest.handler.job.SubtaskCurrentAttemptDetailsHandler
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandler
,org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler
,AutoCloseableAsync
public class SubtaskCurrentAttemptDetailsHandler extends AbstractSubtaskHandler<SubtaskExecutionAttemptDetailsInfo,SubtaskMessageParameters>
Request handler providing details about a single task execution attempt.
-
-
Field Summary
-
Fields inherited from class org.apache.flink.runtime.rest.handler.AbstractHandler
log, MAPPER
-
Fields inherited from class org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler
leaderRetriever, logger, responseHeaders, timeout
-
-
Constructor Summary
Constructors Constructor Description SubtaskCurrentAttemptDetailsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,SubtaskExecutionAttemptDetailsInfo,SubtaskMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor, MetricFetcher metricFetcher)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected SubtaskExecutionAttemptDetailsInfo
handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionVertex executionVertex)
Called for each request after the correspondingAccessExecutionVertex
has been retrieved from theAccessExecutionJobVertex
.-
Methods inherited from class org.apache.flink.runtime.rest.handler.job.AbstractSubtaskHandler
handleRequest
-
Methods inherited from class org.apache.flink.runtime.rest.handler.job.AbstractJobVertexHandler
handleRequest
-
Methods inherited from class org.apache.flink.runtime.rest.handler.job.AbstractAccessExecutionGraphHandler
handleRequest
-
Methods inherited from class org.apache.flink.runtime.rest.handler.job.AbstractExecutionGraphHandler
handleRequest
-
Methods inherited from class org.apache.flink.runtime.rest.handler.AbstractRestHandler
getMessageHeaders, respondToRequest
-
Methods inherited from class org.apache.flink.runtime.rest.handler.AbstractHandler
closeAsync, closeHandlerAsync, respondAsLeader
-
Methods inherited from class org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler
channelRead0, getTimeout
-
Methods inherited from class org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler
acceptInboundMessage, channelRead
-
Methods inherited from class org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandlerAdapter
channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
-
Methods inherited from class org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerAdapter
ensureNotSharable, handlerAdded, handlerRemoved, isSharable
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.flink.util.AutoCloseableAsync
close
-
-
-
-
Constructor Detail
-
SubtaskCurrentAttemptDetailsHandler
public SubtaskCurrentAttemptDetailsHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever, Duration timeout, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,SubtaskExecutionAttemptDetailsInfo,SubtaskMessageParameters> messageHeaders, ExecutionGraphCache executionGraphCache, Executor executor, MetricFetcher metricFetcher)
-
-
Method Detail
-
handleRequest
protected SubtaskExecutionAttemptDetailsInfo handleRequest(HandlerRequest<EmptyRequestBody> request, AccessExecutionVertex executionVertex) throws RestHandlerException
Description copied from class:AbstractSubtaskHandler
Called for each request after the correspondingAccessExecutionVertex
has been retrieved from theAccessExecutionJobVertex
.- Specified by:
handleRequest
in classAbstractSubtaskHandler<SubtaskExecutionAttemptDetailsInfo,SubtaskMessageParameters>
- Parameters:
request
- the requestexecutionVertex
- the execution vertex- Returns:
- the response
- Throws:
RestHandlerException
- the rest handler exception
-
-