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 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 Description (package private) ClientContextclientCtx(package private) longexplicitLac(package private) LedgerHandlelh(package private) static org.slf4j.LoggerLOG(package private) longpiggyBackedLac(package private) java.util.concurrent.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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) voidasyncExplicitLacFlush(long explicitLac)Make a LastAddUpdate request.voidsetPiggyBackedLac(long piggyBackedLac)voidstopExplicitLacFlush()voidupdatePiggyBackedLac(long piggyBackedLac)
-
-
-
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:
stopExplicitLacFlushin interfaceExplicitLacFlushPolicy
-
updatePiggyBackedLac
public void updatePiggyBackedLac(long piggyBackedLac)
- Specified by:
updatePiggyBackedLacin interfaceExplicitLacFlushPolicy
-
-