Uses of Class
org.apache.bookkeeper.proto.BookieRequestHandler
-
Packages that use BookieRequestHandler Package Description org.apache.bookkeeper.bookie Provides a Bookie server that stores entries for clients.org.apache.bookkeeper.processor Define the processors used by bookie from processing requests.org.apache.bookkeeper.proto Classes related to the Bookkeeper protocol. -
-
Uses of BookieRequestHandler in org.apache.bookkeeper.bookie
Method parameters in org.apache.bookkeeper.bookie with type arguments of type BookieRequestHandler Modifier and Type Method Description intJournal.ForceWriteRequest. process(com.carrotsearch.hppc.ObjectHashSet<BookieRequestHandler> writeHandlers) -
Uses of BookieRequestHandler in org.apache.bookkeeper.processor
Methods in org.apache.bookkeeper.processor with parameters of type BookieRequestHandler Modifier and Type Method Description voidRequestProcessor. processRequest(java.lang.Object r, BookieRequestHandler channel)Process request. -
Uses of BookieRequestHandler in org.apache.bookkeeper.proto
Fields in org.apache.bookkeeper.proto declared as BookieRequestHandler Modifier and Type Field Description (package private) BookieRequestHandlerPacketProcessorBase. requestHandler(package private) BookieRequestHandlerPacketProcessorBaseV3. requestHandlerMethods in org.apache.bookkeeper.proto with parameters of type BookieRequestHandler Modifier and Type Method Description static BatchedReadEntryProcessorBatchedReadEntryProcessor. create(BookieProtocol.BatchedReadRequest request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor, java.util.concurrent.ExecutorService fenceThreadPool, boolean throttleReadResponses, long maxBatchReadSize)static ReadEntryProcessorReadEntryProcessor. create(BookieProtocol.ReadRequest request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor, java.util.concurrent.ExecutorService fenceThreadPool, boolean throttleReadResponses)static WriteEntryProcessorWriteEntryProcessor. create(BookieProtocol.ParsedAddRequest request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor)protected voidPacketProcessorBase. init(T request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor)voidBookieRequestProcessor. processRequest(java.lang.Object msg, BookieRequestHandler requestHandler)
-