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 java.lang.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 and Description
(package private) ClientContext	clientCtx
(package private) long	explicitLac
(package private) LedgerHandle	lh
(package private) static org.slf4j.Logger	LOG
(package private) long	piggyBackedLac
(package private) java.util.concurrent.ScheduledFuture<?>	scheduledFuture

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

VOID_EXPLICITLAC_FLUSH_POLICY

Constructor Summary

Constructors

Constructor and Description
ExplicitLacFlushPolicyImpl(LedgerHandle lh, ClientContext clientCtx)

Method Summary

Modifier and Type	Method and 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 Detail

LOG

static final org.slf4j.Logger LOG

piggyBackedLac

volatile long piggyBackedLac

explicitLac

volatile long explicitLac

lh

final LedgerHandle lh

clientCtx

final ClientContext clientCtx

scheduledFuture

java.util.concurrent.ScheduledFuture<?> scheduledFuture

Constructor Detail

ExplicitLacFlushPolicyImpl

ExplicitLacFlushPolicyImpl(LedgerHandle lh,
                           ClientContext clientCtx)

Method Detail

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