@InterfaceAudience.Private public class DefaultMobStoreFlusher extends DefaultStoreFlusher
Modifier and Type | Field and Description |
---|---|
protected Configuration |
conf |
protected Store |
store |
Constructor and Description |
---|
DefaultMobStoreFlusher(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) |
java.util.List<Path> |
flushSnapshot(MemStoreSnapshot snapshot,
long cacheFlushId,
MonitoredTask status)
Flushes the snapshot of the MemStore.
|
protected void |
performFlush(InternalScanner scanner,
Compactor.CellSink sink,
long smallestReadPoint)
Performs memstore flush, writing data from scanner into sink.
|
protected void |
performMobFlush(MemStoreSnapshot snapshot,
long cacheFlushId,
InternalScanner scanner,
StoreFile.Writer writer,
MonitoredTask status)
Flushes the cells in the mob store.
|
protected Configuration conf
protected Store store
public DefaultMobStoreFlusher(Configuration conf, Store store) throws java.io.IOException
java.io.IOException
public java.util.List<Path> flushSnapshot(MemStoreSnapshot snapshot, long cacheFlushId, MonitoredTask status) throws java.io.IOException
flushSnapshot
in class DefaultStoreFlusher
snapshot
- Memstore snapshot.cacheFlushId
- Log cache flush sequence number.status
- Task that represents the flush operation and may be updated with status.java.io.IOException
protected void performMobFlush(MemStoreSnapshot snapshot, long cacheFlushId, InternalScanner scanner, StoreFile.Writer writer, MonitoredTask status) 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.java.io.IOException
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