Package org.apache.bookkeeper.bookie
Class Journal.QueueEntry
java.lang.Object
org.apache.bookkeeper.bookie.Journal.QueueEntry
- All Implemented Interfaces:
Runnable
- Enclosing class:
- Journal
Journal Entry to Record.
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) boolean(package private) Counter(package private) BookkeeperInternalCallbacks.WriteCallback(package private) Object(package private) long(package private) io.netty.buffer.ByteBuf(package private) long(package private) OpStatsLogger(package private) long -
Method Summary
Modifier and TypeMethodDescription(package private) static Journal.QueueEntrycreate(io.netty.buffer.ByteBuf entry, boolean ackBeforeSync, long ledgerId, long entryId, BookkeeperInternalCallbacks.WriteCallback cb, Object ctx, long enqueueTime, OpStatsLogger journalAddEntryStats, Counter callbackTime) voidrun()
-
Field Details
-
entry
io.netty.buffer.ByteBuf entry -
ledgerId
long ledgerId -
entryId
long entryId -
cb
-
ctx
Object ctx -
enqueueTime
long enqueueTime -
ackBeforeSync
boolean ackBeforeSync -
journalAddEntryStats
OpStatsLogger journalAddEntryStats -
callbackTime
Counter callbackTime
-
-
Method Details
-
create
static Journal.QueueEntry create(io.netty.buffer.ByteBuf entry, boolean ackBeforeSync, long ledgerId, long entryId, BookkeeperInternalCallbacks.WriteCallback cb, Object ctx, long enqueueTime, OpStatsLogger journalAddEntryStats, Counter callbackTime) -
run
public void run()
-