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
-
Constructor Summary
ConstructorDescriptionDummyStoreFlusher
(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.regionserver.HStore store) -
Method Summary
Modifier and TypeMethodDescriptionprotected final org.apache.hadoop.hbase.regionserver.InternalScanner
createScanner
(List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> arg0, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker arg1) 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) 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
-
Field Details
-
conf
protected org.apache.hadoop.conf.Configuration conf -
store
protected org.apache.hadoop.hbase.regionserver.HStore store
-
-
Constructor Details
-
DummyStoreFlusher
public DummyStoreFlusher(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.regionserver.HStore store)
-
-
Method Details
-
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
-