Package org.apache.hadoop.hbase.regionserver

Class TestHStore.MyDefaultStoreFlusher

java.lang.Object

org.apache.hadoop.hbase.regionserver.DefaultStoreFlusher

org.apache.hadoop.hbase.regionserver.TestHStore.MyDefaultStoreFlusher

Enclosing class:

TestHStore

public static class TestHStore.MyDefaultStoreFlusher
extends org.apache.hadoop.hbase.regionserver.DefaultStoreFlusher

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.hadoop.conf.Configuration	conf
private static final AtomicInteger	counter
private static final AtomicInteger	failCounter
protected org.apache.hadoop.hbase.regionserver.HStore	store

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected 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)
List<org.apache.hadoop.fs.Path>	flushSnapshot(org.apache.hadoop.hbase.regionserver.MemStoreSnapshot snapshot, long cacheFlushId, org.apache.hadoop.hbase.monitoring.MonitoredTask status, org.apache.hadoop.hbase.regionserver.throttle.ThroughputController throughputController, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker, Consumer<org.apache.hadoop.fs.Path> writerCreationTracker)
protected void	performFlush(org.apache.hadoop.hbase.regionserver.InternalScanner scanner, org.apache.hadoop.hbase.regionserver.CellSink sink, org.apache.hadoop.hbase.regionserver.throttle.ThroughputController throughputController)

Methods inherited from class java.lang.Object

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

Field Details

failCounter

private static final AtomicInteger failCounter

counter

private static final AtomicInteger counter

conf

protected org.apache.hadoop.conf.Configuration conf

store

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

Constructor Details

MyDefaultStoreFlusher

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

Method Details

flushSnapshot

public List<org.apache.hadoop.fs.Path> flushSnapshot(org.apache.hadoop.hbase.regionserver.MemStoreSnapshot snapshot,
 long cacheFlushId,
 org.apache.hadoop.hbase.monitoring.MonitoredTask status,
 org.apache.hadoop.hbase.regionserver.throttle.ThroughputController throughputController,
 org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker,
 Consumer<org.apache.hadoop.fs.Path> writerCreationTracker)
                                              throws IOException

Overrides:

flushSnapshot in class org.apache.hadoop.hbase.regionserver.DefaultStoreFlusher

Throws:

IOException

performFlush

protected void performFlush(org.apache.hadoop.hbase.regionserver.InternalScanner scanner,
 org.apache.hadoop.hbase.regionserver.CellSink sink,
 org.apache.hadoop.hbase.regionserver.throttle.ThroughputController throughputController)
                     throws IOException

Throws:

IOException

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