@InterfaceAudience.Private abstract class StoreFlusher extends Object
Modifier and Type | Field and Description |
---|---|
protected org.apache.hadoop.conf.Configuration |
conf |
protected Store |
store |
Constructor and Description |
---|
StoreFlusher(org.apache.hadoop.conf.Configuration conf,
Store store) |
Modifier and Type | Method and Description |
---|---|
protected InternalScanner |
createScanner(KeyValueScanner snapshotScanner,
long smallestReadPoint)
Creates the scanner for flushing snapshot.
|
protected void |
finalizeWriter(StoreFile.Writer writer,
long cacheFlushSeqNum,
MonitoredTask status) |
abstract List<org.apache.hadoop.fs.Path> |
flushSnapshot(MemStoreSnapshot snapshot,
long cacheFlushSeqNum,
MonitoredTask status)
Turns a snapshot of memstore into a set of store files.
|
protected void |
performFlush(InternalScanner scanner,
Compactor.CellSink sink,
long smallestReadPoint)
Performs memstore flush, writing data from scanner into sink.
|
protected org.apache.hadoop.conf.Configuration conf
protected Store store
public StoreFlusher(org.apache.hadoop.conf.Configuration conf, Store store)
public abstract List<org.apache.hadoop.fs.Path> flushSnapshot(MemStoreSnapshot snapshot, long cacheFlushSeqNum, MonitoredTask status) throws IOException
snapshot
- Memstore snapshot.cacheFlushSeqNum
- Log cache flush sequence number.status
- Task that represents the flush operation and may be updated with status.IOException
protected void finalizeWriter(StoreFile.Writer writer, long cacheFlushSeqNum, MonitoredTask status) throws IOException
IOException
protected InternalScanner createScanner(KeyValueScanner snapshotScanner, long smallestReadPoint) throws IOException
snapshotScanner
- smallestReadPoint
- IOException
protected void performFlush(InternalScanner scanner, Compactor.CellSink sink, long smallestReadPoint) throws IOException
scanner
- Scanner to get data from.sink
- Sink to write data to. Could be StoreFile.Writer.smallestReadPoint
- Smallest read point used for the flush.IOException
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.