@InterfaceAudience.Private public class DefaultStoreFlusher extends StoreFlusher
| Modifier and Type | Field and Description |
|---|---|
private Object |
flushLock |
private static org.apache.commons.logging.Log |
LOG |
conf, store| Constructor and Description |
|---|
DefaultStoreFlusher(org.apache.hadoop.conf.Configuration conf,
Store store) |
| Modifier and Type | Method and Description |
|---|---|
List<org.apache.hadoop.fs.Path> |
flushSnapshot(MemStoreSnapshot snapshot,
long cacheFlushId,
MonitoredTask status)
Turns a snapshot of memstore into a set of store files.
|
createScanner, finalizeWriter, performFlushprivate static final org.apache.commons.logging.Log LOG
private final Object flushLock
public DefaultStoreFlusher(org.apache.hadoop.conf.Configuration conf,
Store store)
public List<org.apache.hadoop.fs.Path> flushSnapshot(MemStoreSnapshot snapshot, long cacheFlushId, MonitoredTask status) throws IOException
StoreFlusherflushSnapshot in class StoreFlushersnapshot - Memstore snapshot.cacheFlushId - Log cache flush sequence number.status - Task that represents the flush operation and may be updated with status.IOExceptionCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.