Package org.apache.bookkeeper.client
Class LedgerRecoveryOp.RecoveryReadOp
- java.lang.Object
-
- org.apache.bookkeeper.client.ReadOpBase
-
- org.apache.bookkeeper.client.PendingReadOp
-
- org.apache.bookkeeper.client.ListenerBasedPendingReadOp
-
- org.apache.bookkeeper.client.LedgerRecoveryOp.RecoveryReadOp
-
- All Implemented Interfaces:
java.lang.Runnable
,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.ParallelReadRequest, PendingReadOp.SequenceReadRequest, PendingReadOp.SingleLedgerEntryRequest
-
Nested classes/interfaces inherited from class org.apache.bookkeeper.client.ReadOpBase
ReadOpBase.LedgerEntryRequest, ReadOpBase.ReadContext
-
-
Field Summary
-
Fields inherited from class org.apache.bookkeeper.client.ListenerBasedPendingReadOp
ctx, listener
-
Fields inherited from class org.apache.bookkeeper.client.PendingReadOp
parallelRead, seq
-
Fields inherited from class org.apache.bookkeeper.client.ReadOpBase
allowFailFast, clientCtx, complete, endEntryId, future, heardFromHosts, heardFromHostsBitSet, isRecoveryRead, lh, numPendingEntries, requestTimeNanos, requiredBookiesMissingEntryForRecovery, sentToHosts, speculativeTask, startEntryId
-
-
Constructor Summary
Constructors Constructor Description RecoveryReadOp(LedgerHandle lh, ClientContext clientCtx, long startEntryId, long endEntryId, BookkeeperInternalCallbacks.ReadEntryListener cb, java.lang.Object ctx)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected LedgerMetadata
getLedgerMetadata()
-
Methods inherited from class org.apache.bookkeeper.client.ListenerBasedPendingReadOp
submitCallback
-
Methods inherited from class org.apache.bookkeeper.client.PendingReadOp
initiate, parallelRead, readEntryComplete, sendReadTo
-
Methods inherited from class org.apache.bookkeeper.client.ReadOpBase
allowFailFastOnUnwritableChannel, cancelSpeculativeTask, future, getSpeculativeTask, run, submit
-
-
-
-
Constructor Detail
-
RecoveryReadOp
RecoveryReadOp(LedgerHandle lh, ClientContext clientCtx, long startEntryId, long endEntryId, BookkeeperInternalCallbacks.ReadEntryListener cb, java.lang.Object ctx)
-
-
Method Detail
-
getLedgerMetadata
protected LedgerMetadata getLedgerMetadata()
- Overrides:
getLedgerMetadata
in classReadOpBase
-
-