Package org.apache.bookkeeper.client

Class ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl

java.lang.Object

org.apache.bookkeeper.client.ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl

All Implemented Interfaces:

ExplicitLacFlushPolicy

Enclosing interface:

ExplicitLacFlushPolicy

public static class ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl
extends Object
implements ExplicitLacFlushPolicy

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.bookkeeper.client.ExplicitLacFlushPolicy

ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final ClientContext	clientCtx
(package private) long	explicitLac
(package private) final LedgerHandle	lh
(package private) static final org.slf4j.Logger	LOG
(package private) long	piggyBackedLac
(package private) ScheduledFuture<?>	scheduledFuture

Fields inherited from interface org.apache.bookkeeper.client.ExplicitLacFlushPolicy

VOID_EXPLICITLAC_FLUSH_POLICY

Constructor Summary

Constructors

Constructor	Description
ExplicitLacFlushPolicyImpl(LedgerHandle lh, ClientContext clientCtx)

Method Summary

Modifier and Type	Method	Description
(package private) void	asyncExplicitLacFlush(long explicitLac)	Make a LastAddUpdate request.
void	setPiggyBackedLac(long piggyBackedLac)
void	stopExplicitLacFlush()
void	updatePiggyBackedLac(long piggyBackedLac)

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

piggyBackedLac

volatile long piggyBackedLac

explicitLac

volatile long explicitLac

lh

final LedgerHandle lh

clientCtx

final ClientContext clientCtx

scheduledFuture

ScheduledFuture<?> scheduledFuture

Constructor Details

ExplicitLacFlushPolicyImpl

ExplicitLacFlushPolicyImpl(LedgerHandle lh,
 ClientContext clientCtx)

Method Details

setPiggyBackedLac

public void setPiggyBackedLac(long piggyBackedLac)

asyncExplicitLacFlush

void asyncExplicitLacFlush(long explicitLac)

Make a LastAddUpdate request.

stopExplicitLacFlush

public void stopExplicitLacFlush()

Specified by:

stopExplicitLacFlush in interface ExplicitLacFlushPolicy

updatePiggyBackedLac

public void updatePiggyBackedLac(long piggyBackedLac)

Specified by:

updatePiggyBackedLac in interface ExplicitLacFlushPolicy