| Package | Description |
|---|---|
| org.apache.bookkeeper.client |
BookKeeper Client.
|
| Modifier and Type | Field and Description |
|---|---|
(package private) java.util.Queue<PendingAddOp> |
LedgerHandle.pendingAddOps |
| Modifier and Type | Method and Description |
|---|---|
(package private) PendingAddOp |
PendingAddOp.allowFailFastOnUnwritableChannel() |
(package private) static PendingAddOp |
PendingAddOp.create(LedgerHandle lh,
ClientContext clientCtx,
java.util.List<org.apache.bookkeeper.net.BookieId> ensemble,
io.netty.buffer.ByteBuf payload,
java.util.EnumSet<WriteFlag> writeFlags,
AsyncCallback.AddCallbackWithLatency cb,
java.lang.Object ctx) |
(package private) PendingAddOp |
PendingAddOp.enableRecoveryAdd()
Enable the recovery add flag for this operation.
|
| Modifier and Type | Method and Description |
|---|---|
(package private) java.util.List<PendingAddOp> |
LedgerHandle.drainPendingAddsAndAdjustLength() |
| Modifier and Type | Method and Description |
|---|---|
int |
LedgerHandleAdv.PendingOpsComparator.compare(PendingAddOp o1,
PendingAddOp o2) |
protected void |
LedgerHandleAdv.doAsyncAddEntry(PendingAddOp op)
Overriding part is mostly around setting entryId.
|
protected void |
LedgerHandle.doAsyncAddEntry(PendingAddOp op) |
| Modifier and Type | Method and Description |
|---|---|
(package private) void |
LedgerHandle.errorOutPendingAdds(int rc,
java.util.List<PendingAddOp> ops) |
Copyright © 2011–2024 The Apache Software Foundation. All rights reserved.