Package org.apache.bookkeeper.bookie

Class Journal.QueueEntry

java.lang.Object

org.apache.bookkeeper.bookie.Journal.QueueEntry

All Implemented Interfaces:

Runnable

Enclosing class:

Journal

static class Journal.QueueEntry
extends Object
implements Runnable

Journal Entry to Record.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) boolean	ackBeforeSync
(package private) Counter	callbackTime
(package private) BookkeeperInternalCallbacks.WriteCallback	cb
(package private) Object	ctx
(package private) long	enqueueTime
(package private) io.netty.buffer.ByteBuf	entry
(package private) long	entryId
(package private) OpStatsLogger	journalAddEntryStats
(package private) long	ledgerId

Method Summary

Modifier and Type	Method	Description
(package private) 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)
void	run()

Methods inherited from class java.lang.Object

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

Field Details

entry

io.netty.buffer.ByteBuf entry

ledgerId

long ledgerId

entryId

long entryId

cb

BookkeeperInternalCallbacks.WriteCallback 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()

Specified by:

run in interface Runnable