Package | Description |
---|---|
org.apache.hadoop.hbase.coprocessor |
Table of Contents
|
org.apache.hadoop.hbase.coprocessor.example | |
org.apache.hadoop.hbase.mob | |
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.security.access |
Modifier and Type | Method and Description |
---|---|
default void |
RegionObserver.postFlush(ObserverContext<RegionCoprocessorEnvironment> c,
FlushLifeCycleTracker tracker)
Called after the memstore is flushed to disk.
|
default void |
RegionObserver.postFlush(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
StoreFile resultFile,
FlushLifeCycleTracker tracker)
Called after a Store's memstore is flushed to disk.
|
default void |
RegionObserver.preFlush(ObserverContext<RegionCoprocessorEnvironment> c,
FlushLifeCycleTracker tracker)
Called before the memstore is flushed to disk.
|
default InternalScanner |
RegionObserver.preFlush(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
InternalScanner scanner,
FlushLifeCycleTracker tracker)
Called before a Store's memstore is flushed to disk.
|
default void |
RegionObserver.preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
ScanOptions options,
FlushLifeCycleTracker tracker)
Called before we open store scanner for flush.
|
Modifier and Type | Method and Description |
---|---|
void |
ExampleRegionObserverWithMetrics.ExampleRegionObserver.postFlush(ObserverContext<RegionCoprocessorEnvironment> c,
FlushLifeCycleTracker tracker) |
void |
ExampleRegionObserverWithMetrics.ExampleRegionObserver.postFlush(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
StoreFile resultFile,
FlushLifeCycleTracker tracker) |
InternalScanner |
WriteHeavyIncrementObserver.preFlush(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
InternalScanner scanner,
FlushLifeCycleTracker tracker) |
void |
WriteHeavyIncrementObserver.preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
ScanOptions options,
FlushLifeCycleTracker tracker) |
void |
ZooKeeperScanPolicyObserver.preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c,
Store store,
ScanOptions options,
FlushLifeCycleTracker tracker) |
Modifier and Type | Method and Description |
---|---|
List<org.apache.hadoop.fs.Path> |
DefaultMobStoreFlusher.flushSnapshot(MemStoreSnapshot snapshot,
long cacheFlushId,
MonitoredTask status,
ThroughputController throughputController,
FlushLifeCycleTracker tracker,
Consumer<org.apache.hadoop.fs.Path> writerCreationTracker)
Flushes the snapshot of the MemStore.
|
Modifier and Type | Field and Description |
---|---|
static FlushLifeCycleTracker |
FlushLifeCycleTracker.DUMMY |
private FlushLifeCycleTracker |
HStore.StoreFlusherImpl.tracker |
private FlushLifeCycleTracker |
MemStoreFlusher.FlushRegionEntry.tracker |
Modifier and Type | Method and Description |
---|---|
FlushLifeCycleTracker |
MemStoreFlusher.FlushRegionEntry.getTracker() |
Modifier and Type | Method and Description |
---|---|
StoreFlushContext |
HStore.createFlushContext(long cacheFlushId,
FlushLifeCycleTracker tracker) |
protected InternalScanner |
StoreFlusher.createScanner(List<KeyValueScanner> snapshotScanners,
FlushLifeCycleTracker tracker)
Creates the scanner for flushing snapshot.
|
(package private) HRegion.FlushResultImpl |
HRegion.flushcache(boolean flushAllStores,
boolean writeFlushRequestWalMarker,
FlushLifeCycleTracker tracker) |
HRegion.FlushResultImpl |
HRegion.flushcache(List<byte[]> families,
boolean writeFlushRequestWalMarker,
FlushLifeCycleTracker tracker)
Flush the cache.
|
protected List<org.apache.hadoop.fs.Path> |
HStore.flushCache(long logCacheFlushId,
MemStoreSnapshot snapshot,
MonitoredTask status,
ThroughputController throughputController,
FlushLifeCycleTracker tracker,
Consumer<org.apache.hadoop.fs.Path> writerCreationTracker)
Write out current snapshot.
|
private boolean |
MemStoreFlusher.flushRegion(HRegion region,
boolean emergencyFlush,
List<byte[]> families,
FlushLifeCycleTracker tracker)
Flush a region.
|
List<org.apache.hadoop.fs.Path> |
DefaultStoreFlusher.flushSnapshot(MemStoreSnapshot snapshot,
long cacheFlushId,
MonitoredTask status,
ThroughputController throughputController,
FlushLifeCycleTracker tracker,
Consumer<org.apache.hadoop.fs.Path> writerCreationTracker) |
abstract List<org.apache.hadoop.fs.Path> |
StoreFlusher.flushSnapshot(MemStoreSnapshot snapshot,
long cacheFlushSeqNum,
MonitoredTask status,
ThroughputController throughputController,
FlushLifeCycleTracker tracker,
Consumer<org.apache.hadoop.fs.Path> writerCreationTracker)
Turns a snapshot of memstore into a set of store files.
|
List<org.apache.hadoop.fs.Path> |
StripeStoreFlusher.flushSnapshot(MemStoreSnapshot snapshot,
long cacheFlushSeqNum,
MonitoredTask status,
ThroughputController throughputController,
FlushLifeCycleTracker tracker,
Consumer<org.apache.hadoop.fs.Path> writerCreationTracker) |
private HRegion.FlushResultImpl |
HRegion.internalFlushcache(Collection<HStore> storesToFlush,
MonitoredTask status,
boolean writeFlushWalMarker,
FlushLifeCycleTracker tracker)
Flushing given stores.
|
protected HRegion.FlushResultImpl |
HRegion.internalFlushcache(WAL wal,
long myseqid,
Collection<HStore> storesToFlush,
MonitoredTask status,
boolean writeFlushWalMarker,
FlushLifeCycleTracker tracker)
Flush the memstore.
|
protected HRegion.PrepareFlushResult |
HRegion.internalPrepareFlushCache(WAL wal,
long myseqid,
Collection<HStore> storesToFlush,
MonitoredTask status,
boolean writeFlushWalMarker,
FlushLifeCycleTracker tracker) |
void |
RegionCoprocessorHost.postFlush(FlushLifeCycleTracker tracker)
Invoked after a memstore flush n
|
void |
RegionCoprocessorHost.postFlush(HStore store,
HStoreFile storeFile,
FlushLifeCycleTracker tracker)
Invoked after a memstore flush n
|
void |
RegionCoprocessorHost.preFlush(FlushLifeCycleTracker tracker)
Invoked before a memstore flush n
|
InternalScanner |
RegionCoprocessorHost.preFlush(HStore store,
InternalScanner scanner,
FlushLifeCycleTracker tracker)
Invoked before a memstore flush
|
ScanInfo |
RegionCoprocessorHost.preFlushScannerOpen(HStore store,
FlushLifeCycleTracker tracker)
Invoked before create StoreScanner for flush.
|
void |
Region.requestFlush(FlushLifeCycleTracker tracker)
Request flush on this region.
|
void |
HRegion.requestFlush(FlushLifeCycleTracker tracker) |
boolean |
FlushRequester.requestFlush(HRegion region,
FlushLifeCycleTracker tracker)
Tell the listener the cache needs to be flushed.
|
boolean |
MemStoreFlusher.requestFlush(HRegion r,
FlushLifeCycleTracker tracker) |
boolean |
FlushRequester.requestFlush(HRegion region,
List<byte[]> families,
FlushLifeCycleTracker tracker)
Tell the listener the cache needs to be flushed.
|
boolean |
MemStoreFlusher.requestFlush(HRegion r,
List<byte[]> families,
FlushLifeCycleTracker tracker) |
private void |
HRegion.requestFlush0(FlushLifeCycleTracker tracker) |
Constructor and Description |
---|
FlushRegionEntry(HRegion r,
List<byte[]> families,
FlushLifeCycleTracker tracker) |
StoreFlusherImpl(long cacheFlushSeqNum,
FlushLifeCycleTracker tracker) |
Modifier and Type | Method and Description |
---|---|
void |
AccessController.preFlush(ObserverContext<RegionCoprocessorEnvironment> c,
FlushLifeCycleTracker tracker) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.