| Package | Description |
|---|---|
| org.apache.bookkeeper.client |
BookKeeper Client.
|
| Modifier and Type | Class and Description |
|---|---|
(package private) static class |
SyncCallbackUtils.SyncCreateAdvCallback |
(package private) static class |
SyncCallbackUtils.SyncCreateCallback |
| Modifier and Type | Field and Description |
|---|---|
(package private) AsyncCallback.CreateCallback |
LedgerCreateOp.cb |
| Modifier and Type | Method and Description |
|---|---|
void |
BookKeeper.asyncCreateLedger(int ensSize,
int writeQuorumSize,
BookKeeper.DigestType digestType,
byte[] passwd,
AsyncCallback.CreateCallback cb,
java.lang.Object ctx)
Creates a new ledger asynchronously.
|
void |
BookKeeper.asyncCreateLedger(int ensSize,
int writeQuorumSize,
int ackQuorumSize,
BookKeeper.DigestType digestType,
byte[] passwd,
AsyncCallback.CreateCallback cb,
java.lang.Object ctx,
java.util.Map<java.lang.String,byte[]> customMetadata)
Creates a new ledger asynchronously.
|
void |
BookKeeper.asyncCreateLedgerAdv(int ensSize,
int writeQuorumSize,
int ackQuorumSize,
BookKeeper.DigestType digestType,
byte[] passwd,
AsyncCallback.CreateCallback cb,
java.lang.Object ctx,
java.util.Map<java.lang.String,byte[]> customMetadata)
Creates a new ledger asynchronously and returns
LedgerHandleAdv
which can accept entryId. |
void |
BookKeeper.asyncCreateLedgerAdv(long ledgerId,
int ensSize,
int writeQuorumSize,
int ackQuorumSize,
BookKeeper.DigestType digestType,
byte[] passwd,
AsyncCallback.CreateCallback cb,
java.lang.Object ctx,
java.util.Map<java.lang.String,byte[]> customMetadata)
Asynchronously creates a new ledger using the interface which accepts a ledgerId as input.
|
| Constructor and Description |
|---|
LedgerCreateOp(BookKeeper bk,
int ensembleSize,
int writeQuorumSize,
int ackQuorumSize,
BookKeeper.DigestType digestType,
byte[] passwd,
AsyncCallback.CreateCallback cb,
java.lang.Object ctx,
java.util.Map<java.lang.String,byte[]> customMetadata,
java.util.EnumSet<WriteFlag> writeFlags,
BookKeeperClientStats clientStats)
Constructor.
|
Copyright © 2011–2024 The Apache Software Foundation. All rights reserved.