Class DefaultStoreFlusher
java.lang.Object
org.apache.hadoop.hbase.regionserver.StoreFlusher
org.apache.hadoop.hbase.regionserver.DefaultStoreFlusher
- Direct Known Subclasses:
DefaultMobStoreFlusher
Default implementation of StoreFlusher.
-
Field Summary
Fields inherited from class org.apache.hadoop.hbase.regionserver.StoreFlusher
conf, store
-
Constructor Summary
ConstructorDescriptionDefaultStoreFlusher
(org.apache.hadoop.conf.Configuration conf, HStore store) -
Method Summary
Modifier and TypeMethodDescriptionList<org.apache.hadoop.fs.Path>
flushSnapshot
(MemStoreSnapshot snapshot, long cacheFlushId, MonitoredTask status, ThroughputController throughputController, FlushLifeCycleTracker tracker, Consumer<org.apache.hadoop.fs.Path> writerCreationTracker) Turns a snapshot of memstore into a set of store files.Methods inherited from class org.apache.hadoop.hbase.regionserver.StoreFlusher
createScanner, createWriter, finalizeWriter, performFlush
-
Field Details
-
LOG
-
flushLock
-
-
Constructor Details
-
DefaultStoreFlusher
-
-
Method Details
-
flushSnapshot
public List<org.apache.hadoop.fs.Path> flushSnapshot(MemStoreSnapshot snapshot, long cacheFlushId, MonitoredTask status, ThroughputController throughputController, FlushLifeCycleTracker tracker, Consumer<org.apache.hadoop.fs.Path> writerCreationTracker) throws IOException Description copied from class:StoreFlusher
Turns a snapshot of memstore into a set of store files.- Specified by:
flushSnapshot
in classStoreFlusher
- Parameters:
snapshot
- Memstore snapshot.cacheFlushId
- Log cache flush sequence number.status
- Task that represents the flush operation and may be updated with status.throughputController
- A controller to avoid flush too fast- Returns:
- List of files written. Can be empty; must not be null.
- Throws:
IOException
-