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 org.apache.hadoop.hbase.regionserver.DefaultStoreFlusher

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.hadoop.conf.Configuration	conf
protected org.apache.hadoop.hbase.regionserver.HStore	store

Constructor Summary

Constructors

Constructor and Description
DummyStoreFlusher(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.regionserver.HStore store)

Method Summary

Modifier and Type	Method and Description
protected org.apache.hadoop.hbase.regionserver.InternalScanner	createScanner(List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> arg0, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker arg1)
protected org.apache.hadoop.hbase.regionserver.StoreFileWriter	createWriter(org.apache.hadoop.hbase.regionserver.MemStoreSnapshot arg0, boolean arg1, Consumer<org.apache.hadoop.fs.Path> arg2)
protected void	finalizeWriter(org.apache.hadoop.hbase.regionserver.StoreFileWriter arg0, long arg1, org.apache.hadoop.hbase.monitoring.MonitoredTask arg2)
protected void	performFlush(org.apache.hadoop.hbase.regionserver.InternalScanner arg0, org.apache.hadoop.hbase.regionserver.CellSink arg1, org.apache.hadoop.hbase.regionserver.throttle.ThroughputController arg2)

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 org.apache.hadoop.conf.Configuration conf

store

protected org.apache.hadoop.hbase.regionserver.HStore store

Constructor Detail

DummyStoreFlusher

public DummyStoreFlusher(org.apache.hadoop.conf.Configuration conf,
                         org.apache.hadoop.hbase.regionserver.HStore store)

Method Detail

finalizeWriter

protected void finalizeWriter(org.apache.hadoop.hbase.regionserver.StoreFileWriter arg0,
                              long arg1,
                              org.apache.hadoop.hbase.monitoring.MonitoredTask arg2)
                       throws IOException

Throws:

IOException

createWriter

protected final org.apache.hadoop.hbase.regionserver.StoreFileWriter createWriter(org.apache.hadoop.hbase.regionserver.MemStoreSnapshot arg0,
                                                                                  boolean arg1,
                                                                                  Consumer<org.apache.hadoop.fs.Path> arg2)
                                                                           throws IOException

Throws:

IOException

createScanner

protected final org.apache.hadoop.hbase.regionserver.InternalScanner createScanner(List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> arg0,
                                                                                   org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker arg1)
                                                                            throws IOException

Throws:

IOException

performFlush

protected void performFlush(org.apache.hadoop.hbase.regionserver.InternalScanner arg0,
                            org.apache.hadoop.hbase.regionserver.CellSink arg1,
                            org.apache.hadoop.hbase.regionserver.throttle.ThroughputController arg2)
                     throws IOException

Throws:

IOException