@InterfaceAudience.Private public class DefaultStoreFlusher extends StoreFlusher
Modifier and Type | Field and Description |
---|---|
private Object |
flushLock |
private static org.slf4j.Logger |
LOG |
conf, store
Constructor and Description |
---|
DefaultStoreFlusher(org.apache.hadoop.conf.Configuration conf,
HStore store) |
Modifier and Type | Method and Description |
---|---|
List<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.
|
createScanner, createWriter, finalizeWriter, performFlush
public DefaultStoreFlusher(org.apache.hadoop.conf.Configuration conf, HStore store)
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
StoreFlusher
flushSnapshot
in class StoreFlusher
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 fastIOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.