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 int
Journal.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 void
RequestProcessor. 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) BookieRequestHandler
PacketProcessorBase. requestHandler
(package private) BookieRequestHandler
PacketProcessorBaseV3. requestHandler
Methods in org.apache.bookkeeper.proto with parameters of type BookieRequestHandler Modifier and Type Method Description static BatchedReadEntryProcessor
BatchedReadEntryProcessor. create(BookieProtocol.BatchedReadRequest request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor, java.util.concurrent.ExecutorService fenceThreadPool, boolean throttleReadResponses, long maxBatchReadSize)
static ReadEntryProcessor
ReadEntryProcessor. create(BookieProtocol.ReadRequest request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor, java.util.concurrent.ExecutorService fenceThreadPool, boolean throttleReadResponses)
static WriteEntryProcessor
WriteEntryProcessor. create(BookieProtocol.ParsedAddRequest request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor)
protected void
PacketProcessorBase. init(T request, BookieRequestHandler requestHandler, BookieRequestProcessor requestProcessor)
void
BookieRequestProcessor. processRequest(java.lang.Object msg, BookieRequestHandler requestHandler)
-