Package org.apache.bookkeeper.proto

Class BookieProtocol.BatchedReadRequest

java.lang.Object

org.apache.bookkeeper.proto.BookieProtocol.Request

org.apache.bookkeeper.proto.BookieProtocol.ReadRequest

org.apache.bookkeeper.proto.BookieProtocol.BatchedReadRequest

Enclosing interface:

BookieProtocol

public static class BookieProtocol.BatchedReadRequest
extends BookieProtocol.ReadRequest

The request for reading data with batch optimization. The ledger_id and entry_id will be used as start_ledger_id and start_entry_id. And the batch read operation can only happen on one ledger.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) int	maxCount
(package private) long	maxSize
(package private) long	requestId

Fields inherited from class org.apache.bookkeeper.proto.BookieProtocol.Request

entryId, flags, ledgerId, masterKey, opCode, protocolVersion

Method Summary

Modifier and Type	Method	Description
(package private) static BookieProtocol.BatchedReadRequest	create(byte protocolVersion, long ledgerId, long entryId, short flags, byte[] masterKey, long requestId, int maxCount, long maxSize)
(package private) int	getMaxCount()
(package private) long	getMaxSize()
(package private) long	getRequestId()
void	recycle()

Methods inherited from class org.apache.bookkeeper.proto.BookieProtocol.ReadRequest

create, isFencing

Methods inherited from class org.apache.bookkeeper.proto.BookieProtocol.Request

getEntryId, getFlags, getLedgerId, getMasterKey, getOpCode, getProtocolVersion, hasMasterKey, init, isHighPriority, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

requestId

long requestId

maxCount

int maxCount

maxSize

long maxSize

Method Details

create

static BookieProtocol.BatchedReadRequest create(byte protocolVersion,
 long ledgerId,
 long entryId,
 short flags,
 byte[] masterKey,
 long requestId,
 int maxCount,
 long maxSize)

getMaxCount

int getMaxCount()

getMaxSize

long getMaxSize()

getRequestId

long getRequestId()

recycle

public void recycle()

Overrides:

recycle in class BookieProtocol.ReadRequest