| Package | Description |
|---|---|
| org.apache.bookkeeper.client |
BookKeeper Client.
|
| org.apache.bookkeeper.conf |
Configurations used by bookkeeper.
|
| Modifier and Type | Field and Description |
|---|---|
(package private) BookKeeper.DigestType |
LedgerCreateOp.digestType |
(package private) BookKeeper.DigestType |
LedgerOpenOp.suggestedDigestType |
| Modifier and Type | Method and Description |
|---|---|
static BookKeeper.DigestType |
BookKeeper.DigestType.fromApiDigestType(DigestType digestType) |
static BookKeeper.DigestType |
BookKeeper.DigestType.valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.
|
static BookKeeper.DigestType[] |
BookKeeper.DigestType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
| 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.
|
void |
BookKeeper.asyncOpenLedger(long lId,
BookKeeper.DigestType digestType,
byte[] passwd,
AsyncCallback.OpenCallback cb,
java.lang.Object ctx)
Open existing ledger asynchronously for reading.
|
void |
BookKeeper.asyncOpenLedgerNoRecovery(long lId,
BookKeeper.DigestType digestType,
byte[] passwd,
AsyncCallback.OpenCallback cb,
java.lang.Object ctx)
Open existing ledger asynchronously for reading, but it does not try to
recover the ledger if it is not yet closed.
|
LedgerHandle |
BookKeeper.createLedger(BookKeeper.DigestType digestType,
byte[] passwd)
Creates a new ledger.
|
LedgerHandle |
BookKeeper.createLedger(int ensSize,
int qSize,
BookKeeper.DigestType digestType,
byte[] passwd)
Synchronous call to create ledger.
|
LedgerHandle |
BookKeeper.createLedger(int ensSize,
int writeQuorumSize,
int ackQuorumSize,
BookKeeper.DigestType digestType,
byte[] passwd)
Synchronous call to create ledger.
|
LedgerHandle |
BookKeeper.createLedger(int ensSize,
int writeQuorumSize,
int ackQuorumSize,
BookKeeper.DigestType digestType,
byte[] passwd,
java.util.Map<java.lang.String,byte[]> customMetadata)
Synchronous call to create ledger.
|
LedgerHandle |
BookKeeper.createLedgerAdv(int ensSize,
int writeQuorumSize,
int ackQuorumSize,
BookKeeper.DigestType digestType,
byte[] passwd)
Synchronous call to create ledger.
|
LedgerHandle |
BookKeeper.createLedgerAdv(int ensSize,
int writeQuorumSize,
int ackQuorumSize,
BookKeeper.DigestType digestType,
byte[] passwd,
java.util.Map<java.lang.String,byte[]> customMetadata)
Synchronous call to create ledger.
|
LedgerHandle |
BookKeeper.createLedgerAdv(long ledgerId,
int ensSize,
int writeQuorumSize,
int ackQuorumSize,
BookKeeper.DigestType digestType,
byte[] passwd,
java.util.Map<java.lang.String,byte[]> customMetadata)
Synchronously creates a new ledger using the interface which accepts a ledgerId as input.
|
LedgerHandle |
BookKeeper.openLedger(long lId,
BookKeeper.DigestType digestType,
byte[] passwd)
Synchronous open ledger call.
|
LedgerHandle |
BookKeeper.openLedgerNoRecovery(long lId,
BookKeeper.DigestType digestType,
byte[] passwd)
Synchronous, unsafe open ledger call.
|
static org.apache.bookkeeper.proto.DataFormats.LedgerMetadataFormat.DigestType |
BookKeeper.DigestType.toProtoDigestType(BookKeeper.DigestType digestType) |
| 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.
|
LedgerHandle(ClientContext clientCtx,
long ledgerId,
org.apache.bookkeeper.versioning.Versioned<LedgerMetadata> versionedMetadata,
BookKeeper.DigestType digestType,
byte[] password,
java.util.EnumSet<WriteFlag> writeFlags) |
LedgerHandleAdv(ClientContext clientCtx,
long ledgerId,
org.apache.bookkeeper.versioning.Versioned<LedgerMetadata> metadata,
BookKeeper.DigestType digestType,
byte[] password,
java.util.EnumSet<WriteFlag> writeFlags) |
LedgerOpenOp(BookKeeper bk,
BookKeeperClientStats clientStats,
long ledgerId,
BookKeeper.DigestType digestType,
byte[] passwd,
AsyncCallback.OpenCallback cb,
java.lang.Object ctx)
Constructor.
|
ReadOnlyLedgerHandle(ClientContext clientCtx,
long ledgerId,
org.apache.bookkeeper.versioning.Versioned<LedgerMetadata> metadata,
BookKeeper.DigestType digestType,
byte[] password,
boolean watch) |
| Modifier and Type | Method and Description |
|---|---|
BookKeeper.DigestType |
ClientConfiguration.getBookieRecoveryDigestType()
Get digest type used in bookkeeper admin.
|
| Modifier and Type | Method and Description |
|---|---|
ClientConfiguration |
ClientConfiguration.setBookieRecoveryDigestType(BookKeeper.DigestType digestType)
Set digest type used in bookkeeper admin.
|
Copyright © 2011–2024 The Apache Software Foundation. All rights reserved.