Package | Description |
---|---|
org.apache.hadoop.hbase.regionserver.wal |
Modifier and Type | Field and Description |
---|---|
private SyncFuture |
RingBufferTruck.sync
Either this syncFuture is set or entry is set, but not both.
|
Modifier and Type | Field and Description |
---|---|
private static Comparator<SyncFuture> |
AbstractFSWAL.SEQ_COMPARATOR |
private org.apache.hbase.thirdparty.com.google.common.cache.Cache<Thread,SyncFuture> |
SyncFutureCache.syncFutureCache |
protected SortedSet<SyncFuture> |
AbstractFSWAL.syncFutures |
Modifier and Type | Method and Description |
---|---|
SyncFuture |
SyncFutureCache.getIfPresentOrNew() |
protected SyncFuture |
AbstractFSWAL.getSyncFuture(long sequence,
boolean forceSync) |
(package private) SyncFuture |
SyncFuture.reset(long txid,
boolean forceSync)
Call this method to clear old usage and get it ready for new deploy.
|
(package private) SyncFuture |
RingBufferTruck.unloadSync()
Unload the truck of its
SyncFuture payload. |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractFSWAL.blockOnSync(SyncFuture syncFuture) |
(package private) void |
RingBufferTruck.load(SyncFuture syncFuture)
Load the truck with a
SyncFuture . |
protected void |
AbstractFSWAL.markFutureDoneAndOffer(SyncFuture future,
long txid,
Throwable t)
Helper that marks the future as DONE and offers it back to the cache.
|
void |
SyncFutureCache.offer(SyncFuture syncFuture)
Offers the sync future back to the cache for reuse.
|
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.