Class TriggerSessionHeartbeatHandler
- 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<NonLeaderRetrievalRestfulGateway,R,M>
-
- org.apache.flink.table.gateway.rest.handler.AbstractSqlGatewayRestHandler<EmptyRequestBody,EmptyResponseBody,SessionMessageParameters>
-
- org.apache.flink.table.gateway.rest.handler.session.TriggerSessionHeartbeatHandler
-
- 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 TriggerSessionHeartbeatHandler extends AbstractSqlGatewayRestHandler<EmptyRequestBody,EmptyResponseBody,SessionMessageParameters>
Handler to touch the session.
-
-
Field Summary
-
Fields inherited from class org.apache.flink.table.gateway.rest.handler.AbstractSqlGatewayRestHandler
service
-
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 TriggerSessionHeartbeatHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,EmptyResponseBody,SessionMessageParameters> messageHeaders)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected CompletableFuture<EmptyResponseBody>
handleRequest(SqlGatewayRestAPIVersion version, HandlerRequest<EmptyRequestBody> request)
This method is called for every incoming request and returns aCompletableFuture
containing a the response.-
Methods inherited from class org.apache.flink.table.gateway.rest.handler.AbstractSqlGatewayRestHandler
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
-
TriggerSessionHeartbeatHandler
public TriggerSessionHeartbeatHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,EmptyResponseBody,SessionMessageParameters> messageHeaders)
-
-
Method Detail
-
handleRequest
protected CompletableFuture<EmptyResponseBody> handleRequest(SqlGatewayRestAPIVersion version, @Nonnull HandlerRequest<EmptyRequestBody> request) throws RestHandlerException
Description copied from class:AbstractSqlGatewayRestHandler
This method is called for every incoming request and returns aCompletableFuture
containing a the response.Implementations may decide whether to throw
RestHandlerException
s or fail the returnedCompletableFuture
with aRestHandlerException
.Failing the future with another exception type or throwing unchecked exceptions is regarded as an implementation error as it does not allow us to provide a meaningful HTTP status code. In this case a
HttpResponseStatus.INTERNAL_SERVER_ERROR
will be returned.- Specified by:
handleRequest
in classAbstractSqlGatewayRestHandler<EmptyRequestBody,EmptyResponseBody,SessionMessageParameters>
- Parameters:
version
- request versionrequest
- request that should be handled- Returns:
- future containing a handler response
- Throws:
RestHandlerException
- if the handling failed
-
-