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) 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 Description ExplicitLacFlushPolicyImpl(LedgerHandle lh, ClientContext clientCtx)
-
Method Summary
All Methods Instance Methods Concrete Methods 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)
-
-
-
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 interfaceExplicitLacFlushPolicy
-
updatePiggyBackedLac
public void updatePiggyBackedLac(long piggyBackedLac)
- Specified by:
updatePiggyBackedLac
in interfaceExplicitLacFlushPolicy
-
-