Package org.apache.bookkeeper.client

Class LedgerCreateOp

java.lang.Object

org.apache.bookkeeper.client.LedgerCreateOp

class LedgerCreateOp
extends Object

Encapsulates asynchronous ledger create operation.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	LedgerCreateOp.CreateBuilderImpl

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final int	ackQuorumSize
(package private) boolean	adv
(package private) final BookKeeper	bk
(package private) final AsyncCallback.CreateCallback	cb
(package private) final BookKeeperClientStats	clientStats
(package private) final OpStatsLogger	createOpLogger
(package private) final Object	ctx
(package private) final Map<String,byte[]>	customMetadata
(package private) final BookKeeper.DigestType	digestType
(package private) final int	ensembleSize
(package private) boolean	generateLedgerId
(package private) long	ledgerId
(package private) LedgerHandle	lh
(package private) static final org.slf4j.Logger	LOG
(package private) LedgerMetadata	metadata
(package private) final int	metadataFormatVersion
(package private) final byte[]	passwd
(package private) final long	startTime
(package private) final EnumSet<WriteFlag>	writeFlags
(package private) final int	writeQuorumSize

Constructor Summary

Constructors

Constructor	Description
LedgerCreateOp(BookKeeper bk, int ensembleSize, int writeQuorumSize, int ackQuorumSize, BookKeeper.DigestType digestType, byte[] passwd, AsyncCallback.CreateCallback cb, Object ctx, Map<String,byte[]> customMetadata, EnumSet<WriteFlag> writeFlags, BookKeeperClientStats clientStats)	Constructor.

Method Summary

Modifier and Type	Method	Description
(package private) void	generateLedgerIdAndCreateLedger(LedgerMetadataBuilder metadataBuilder)
void	initiate()	Initiates the operation.
void	initiateAdv(long ledgerId)	Initiates the operation to return LedgerHandleAdv.

Methods inherited from class java.lang.Object

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

Field Details

LOG

static final org.slf4j.Logger LOG

cb

final AsyncCallback.CreateCallback cb

metadata

LedgerMetadata metadata

lh

LedgerHandle lh

ledgerId

long ledgerId

ctx

final Object ctx

ensembleSize

final int ensembleSize

writeQuorumSize

final int writeQuorumSize

ackQuorumSize

final int ackQuorumSize

customMetadata

final Map<String,byte[]> customMetadata

metadataFormatVersion

final int metadataFormatVersion

passwd

final byte[] passwd

bk

final BookKeeper bk

digestType

final BookKeeper.DigestType digestType

writeFlags

final EnumSet<WriteFlag> writeFlags

startTime

final long startTime

createOpLogger

final OpStatsLogger createOpLogger

clientStats

final BookKeeperClientStats clientStats

adv

boolean adv

generateLedgerId

boolean generateLedgerId

Constructor Details

LedgerCreateOp

LedgerCreateOp(BookKeeper bk,
 int ensembleSize,
 int writeQuorumSize,
 int ackQuorumSize,
 BookKeeper.DigestType digestType,
 byte[] passwd,
 AsyncCallback.CreateCallback cb,
 Object ctx,
 Map<String,byte[]> customMetadata,
 EnumSet<WriteFlag> writeFlags,
 BookKeeperClientStats clientStats)

Constructor.

Parameters:

bk - BookKeeper object

ensembleSize - ensemble size

writeQuorumSize - write quorum size

ackQuorumSize - ack quorum size

digestType - digest type, either MAC or CRC32

passwd - password

cb - callback implementation

ctx - optional control object

customMetadata - A map of user specified custom metadata about the ledger to be persisted; will not try to preserve the order(e.g. sortedMap) upon later retireval.

Method Details

initiate

public void initiate()

Initiates the operation.

generateLedgerIdAndCreateLedger

void generateLedgerIdAndCreateLedger(LedgerMetadataBuilder metadataBuilder)

initiateAdv

public void initiateAdv(long ledgerId)

Initiates the operation to return LedgerHandleAdv.