public static class TestDefaultStoreEngine.DummyStoreFlusher extends DefaultStoreFlusher
Modifier and Type | Field and Description |
---|---|
protected Configuration |
conf |
protected Store |
store |
Constructor and Description |
---|
DummyStoreFlusher(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) |
protected void |
performFlush(InternalScanner scanner,
Compactor.CellSink sink,
long smallestReadPoint)
Performs memstore flush, writing data from scanner into sink.
|
flushSnapshot
protected Configuration conf
protected Store store
public DummyStoreFlusher(Configuration conf, Store store)
protected void finalizeWriter(StoreFile.Writer writer, long cacheFlushSeqNum, MonitoredTask status) throws java.io.IOException
java.io.IOException
protected InternalScanner createScanner(KeyValueScanner snapshotScanner, long smallestReadPoint) throws java.io.IOException
snapshotScanner
- smallestReadPoint
- java.io.IOException
protected void performFlush(InternalScanner scanner, Compactor.CellSink sink, long smallestReadPoint) throws java.io.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.java.io.IOException