public static class ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl extends java.lang.Object implements ExplicitLacFlushPolicy
ExplicitLacFlushPolicy.ExplicitLacFlushPolicyImpl
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 |
VOID_EXPLICITLAC_FLUSH_POLICY
Constructor and Description |
---|
ExplicitLacFlushPolicyImpl(LedgerHandle lh,
ClientContext clientCtx) |
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) |
static final org.slf4j.Logger LOG
volatile long piggyBackedLac
volatile long explicitLac
final LedgerHandle lh
final ClientContext clientCtx
java.util.concurrent.ScheduledFuture<?> scheduledFuture
ExplicitLacFlushPolicyImpl(LedgerHandle lh, ClientContext clientCtx)
public void setPiggyBackedLac(long piggyBackedLac)
void asyncExplicitLacFlush(long explicitLac)
public void stopExplicitLacFlush()
stopExplicitLacFlush
in interface ExplicitLacFlushPolicy
public void updatePiggyBackedLac(long piggyBackedLac)
updatePiggyBackedLac
in interface ExplicitLacFlushPolicy
Copyright © 2011–2020 The Apache Software Foundation. All rights reserved.