Package org.apache.flink.queryablestate.server

Class KvStateServerHandler

  • All Implemented Interfaces:
    org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandler, org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler
    @Internal
@Sharable
public class KvStateServerHandler
extends org.apache.flink.queryablestate.network.AbstractServerHandler<KvStateInternalRequest,​org.apache.flink.queryablestate.messages.KvStateResponse>
    This handler dispatches asynchronous tasks, which query InternalKvState instances and write the result to the channel.

    The network threads receive the message, deserialize it and dispatch the query task. The actual query is handled in a separate thread as it might otherwise block the network threads (file I/O etc.).

    • Nested Class Summary

      • Nested classes/interfaces inherited from interface org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandler

        org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandler.Sharable

    • Field Summary

      • Fields inherited from class org.apache.flink.queryablestate.network.AbstractServerHandler

        queryExecutor

    • Constructor Summary

      Constructors 
      Constructor Description
      KvStateServerHandler​(KvStateServerImpl server, org.apache.flink.runtime.query.KvStateRegistry kvStateRegistry, org.apache.flink.queryablestate.network.messages.MessageSerializer<KvStateInternalRequest,​org.apache.flink.queryablestate.messages.KvStateResponse> serializer, org.apache.flink.queryablestate.network.stats.KvStateRequestStats stats)
      Create the handler used by the KvStateServerImpl.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      CompletableFuture<org.apache.flink.queryablestate.messages.KvStateResponse> handleRequest​(long requestId, KvStateInternalRequest request)  
      CompletableFuture<Void> shutdown()  

      • Methods inherited from class org.apache.flink.queryablestate.network.AbstractServerHandler

        channelActive, channelInactive, channelRead, exceptionCaught, getServerName

      • Methods inherited from class org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandlerAdapter

        channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered

      • Methods inherited from class org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerAdapter

        ensureNotSharable, handlerAdded, handlerRemoved, isSharable

      • Methods inherited from interface org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandler

        handlerAdded, handlerRemoved

    • Constructor Detail

      • KvStateServerHandler

        public KvStateServerHandler​(KvStateServerImpl server,
                            org.apache.flink.runtime.query.KvStateRegistry kvStateRegistry,
                            org.apache.flink.queryablestate.network.messages.MessageSerializer<KvStateInternalRequest,​org.apache.flink.queryablestate.messages.KvStateResponse> serializer,
                            org.apache.flink.queryablestate.network.stats.KvStateRequestStats stats)
        Create the handler used by the KvStateServerImpl.
        Parameters:
        server - the KvStateServerImpl using the handler.
        kvStateRegistry - registry to query.
        serializer - the MessageSerializer used to (de-) serialize the different messages.
        stats - server statistics collector.

    • Method Detail

      • handleRequest

        public CompletableFuture<org.apache.flink.queryablestate.messages.KvStateResponse> handleRequest​(long requestId,
                                                                                                 KvStateInternalRequest request)
        Specified by:
        handleRequest in class org.apache.flink.queryablestate.network.AbstractServerHandler<KvStateInternalRequest,​org.apache.flink.queryablestate.messages.KvStateResponse>

      • shutdown

        public CompletableFuture<Void> shutdown()
        Specified by:
        shutdown in class org.apache.flink.queryablestate.network.AbstractServerHandler<KvStateInternalRequest,​org.apache.flink.queryablestate.messages.KvStateResponse>