public class DefaultMobStoreFlusher
extends DefaultStoreFlusher
Constructor and Description |
---|
DefaultMobStoreFlusher(Configuration conf,
HStore store) |
Modifier and Type | Method and Description |
---|---|
java.util.List<Path> |
flushSnapshot(MemStoreSnapshot snapshot,
long cacheFlushId,
MonitoredTask status,
ThroughputController throughputController,
FlushLifeCycleTracker tracker)
Flushes the snapshot of the MemStore.
|
protected void |
performMobFlush(MemStoreSnapshot snapshot,
long cacheFlushId,
InternalScanner scanner,
StoreFileWriter writer,
MonitoredTask status,
ThroughputController throughputController)
Flushes the cells in the mob store.
|
public DefaultMobStoreFlusher(Configuration conf, HStore store) throws java.io.IOException
java.io.IOException
public java.util.List<Path> flushSnapshot(MemStoreSnapshot snapshot, long cacheFlushId, MonitoredTask status, ThroughputController throughputController, FlushLifeCycleTracker tracker) throws java.io.IOException
java.io.IOException
protected void performMobFlush(MemStoreSnapshot snapshot, long cacheFlushId, InternalScanner scanner, StoreFileWriter writer, MonitoredTask status, ThroughputController throughputController) throws java.io.IOException
snapshot
- Memstore snapshot.cacheFlushId
- Log cache flush sequence number.scanner
- The scanner of memstore snapshot.writer
- The store file writer.status
- Task that represents the flush operation and may be updated with status.throughputController
- A controller to avoid flush too fast.java.io.IOException