org.apache.bookkeeper.client

Class LedgerRecoveryOp.RecoveryReadOp

java.lang.Object

org.apache.bookkeeper.client.PendingReadOp

org.apache.bookkeeper.client.ListenerBasedPendingReadOp

org.apache.bookkeeper.client.LedgerRecoveryOp.RecoveryReadOp

All Implemented Interfaces:

java.lang.Runnable, org.apache.bookkeeper.common.util.SafeRunnable, org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.ReadEntryCallback

Enclosing class:

LedgerRecoveryOp

class LedgerRecoveryOp.RecoveryReadOp
extends ListenerBasedPendingReadOp

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.bookkeeper.client.PendingReadOp

PendingReadOp.LedgerEntryRequest, PendingReadOp.ParallelReadRequest, PendingReadOp.SequenceReadRequest

Field Summary

Fields inherited from class org.apache.bookkeeper.client.ListenerBasedPendingReadOp

ctx, listener

Fields inherited from class org.apache.bookkeeper.client.PendingReadOp

allowFailFast, clientCtx, complete, endEntryId, isRecoveryRead, lh, numPendingEntries, parallelRead, requestTimeNanos, requiredBookiesMissingEntryForRecovery, seq, startEntryId

Fields inherited from interface org.apache.bookkeeper.common.util.SafeRunnable

LOGGER

Constructor Summary

Constructors

Constructor and Description
RecoveryReadOp(LedgerHandle lh, ClientContext clientCtx, long startEntryId, long endEntryId, org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.ReadEntryListener cb, java.lang.Object ctx)

Method Summary

Modifier and Type	Method and Description
protected LedgerMetadata	getLedgerMetadata()

Methods inherited from class org.apache.bookkeeper.client.ListenerBasedPendingReadOp

submitCallback

Methods inherited from class org.apache.bookkeeper.client.PendingReadOp

allowFailFastOnUnwritableChannel, cancelSpeculativeTask, future, getSpeculativeTask, initiate, parallelRead, readEntryComplete, safeRun, sendReadTo, submit

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.bookkeeper.common.util.SafeRunnable

run, safeRun, safeRun

Constructor Detail

RecoveryReadOp

RecoveryReadOp(LedgerHandle lh,
               ClientContext clientCtx,
               long startEntryId,
               long endEntryId,
               org.apache.bookkeeper.proto.BookkeeperInternalCallbacks.ReadEntryListener cb,
               java.lang.Object ctx)

Method Detail

getLedgerMetadata

protected LedgerMetadata getLedgerMetadata()

Overrides:

getLedgerMetadata in class PendingReadOp