org.apache.hadoop.hbase.regionserver

Class TestDefaultStoreEngine.DummyStoreFlusher

java.lang.Object

org.apache.hadoop.hbase.regionserver.DefaultStoreFlusher

org.apache.hadoop.hbase.regionserver.TestDefaultStoreEngine.DummyStoreFlusher

Enclosing class:

TestDefaultStoreEngine

public static class TestDefaultStoreEngine.DummyStoreFlusher
extends DefaultStoreFlusher

Field Summary

Fields

Modifier and Type	Field and Description
protected Configuration	conf
protected Store	store

Constructor Summary

Constructors

Constructor and Description
DummyStoreFlusher(Configuration conf, Store store)

Method Summary

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.

Methods inherited from class org.apache.hadoop.hbase.regionserver.DefaultStoreFlusher

flushSnapshot

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

conf

protected Configuration conf

store

protected Store store

Constructor Detail

DummyStoreFlusher

public DummyStoreFlusher(Configuration conf,
                         Store store)

Method Detail

finalizeWriter

protected void finalizeWriter(StoreFile.Writer writer,
                              long cacheFlushSeqNum,
                              MonitoredTask status)
                       throws IOException

Throws:

IOException

createScanner

protected InternalScanner createScanner(KeyValueScanner snapshotScanner,
                                        long smallestReadPoint)
                                 throws IOException

Creates the scanner for flushing snapshot. Also calls coprocessors.

Parameters:

snapshotScanner -

smallestReadPoint -

Returns:

The scanner; null if coprocessor is canceling the flush.

Throws:

IOException

performFlush

protected void performFlush(InternalScanner scanner,
                            Compactor.CellSink sink,
                            long smallestReadPoint)
                     throws IOException

Performs memstore flush, writing data from scanner into sink.

Parameters:

scanner - Scanner to get data from.

sink - Sink to write data to. Could be StoreFile.Writer.

smallestReadPoint - Smallest read point used for the flush.

Throws:

IOException