Package com.linkedin.venice.listener

Class StorageReadRequestHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

com.linkedin.venice.listener.StorageReadRequestHandler

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler

@Sharable
public class StorageReadRequestHandler
extends io.netty.channel.ChannelInboundHandlerAdapter

StorageReadRequestHandler will take the incoming read requests from routerRouterRequest, and delegate the lookup request to a thread pool executor, which is being shared by all the requests. Especially, this handler will execute parallel lookups for MultiGetRouterRequestWrapper.

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor

Description

StorageReadRequestHandler(java.util.concurrent.ThreadPoolExecutor executor, java.util.concurrent.ThreadPoolExecutor computeExecutor, StorageEngineRepository storageEngineRepository, ReadOnlyStoreRepository metadataStoreRepository, ReadOnlySchemaRepository schemaRepository, IngestionMetadataRetriever ingestionMetadataRetriever, ReadMetadataRetriever readMetadataRetriever, DiskHealthCheckService healthCheckService, boolean fastAvroEnabled, boolean parallelBatchGetEnabled, int parallelBatchGetChunkSize, VeniceServerConfig serverConfig, StorageEngineBackedCompressorFactory compressorFactory, java.util.Optional<ResourceReadUsageTracker> resourceReadUsageTracker)

Method Summary

Modifier and Type	Method	Description
void	channelRead(io.netty.channel.ChannelHandlerContext context, java.lang.Object message)
ReadResponse	handleMultiGetRequest(MultiGetRouterRequestWrapper request)
ReadResponse	handleSingleGetRequest(GetRouterRequest request)

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered

Methods inherited from class 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 io.netty.channel.ChannelHandler

handlerAdded, handlerRemoved

Constructor Detail

StorageReadRequestHandler

public StorageReadRequestHandler(java.util.concurrent.ThreadPoolExecutor executor,
                                 java.util.concurrent.ThreadPoolExecutor computeExecutor,
                                 StorageEngineRepository storageEngineRepository,
                                 ReadOnlyStoreRepository metadataStoreRepository,
                                 ReadOnlySchemaRepository schemaRepository,
                                 IngestionMetadataRetriever ingestionMetadataRetriever,
                                 ReadMetadataRetriever readMetadataRetriever,
                                 DiskHealthCheckService healthCheckService,
                                 boolean fastAvroEnabled,
                                 boolean parallelBatchGetEnabled,
                                 int parallelBatchGetChunkSize,
                                 VeniceServerConfig serverConfig,
                                 StorageEngineBackedCompressorFactory compressorFactory,
                                 java.util.Optional<ResourceReadUsageTracker> resourceReadUsageTracker)

Method Detail

channelRead

public void channelRead(io.netty.channel.ChannelHandlerContext context,
                        java.lang.Object message)
                 throws java.lang.Exception

Specified by:

channelRead in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelRead in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

java.lang.Exception

handleSingleGetRequest

public ReadResponse handleSingleGetRequest(GetRouterRequest request)

handleMultiGetRequest

public ReadResponse handleMultiGetRequest(MultiGetRouterRequestWrapper request)