org.apache.hadoop.hbase.regionserver.wal

Class AbstractTestWALReplay.CustomStoreFlusher

java.lang.Object

org.apache.hadoop.hbase.regionserver.DefaultStoreFlusher

org.apache.hadoop.hbase.regionserver.wal.AbstractTestWALReplay.CustomStoreFlusher

Enclosing class:

AbstractTestWALReplay

public static class AbstractTestWALReplay.CustomStoreFlusher
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
(package private) static AtomicBoolean	throwExceptionWhenFlushing

Constructor Summary

Constructors

Constructor and Description
CustomStoreFlusher(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, long arg1, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker 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)
protected void	performFlush(org.apache.hadoop.hbase.regionserver.InternalScanner arg0, org.apache.hadoop.hbase.regionserver.CellSink arg1, long arg2, org.apache.hadoop.hbase.regionserver.throttle.ThroughputController arg3)

Methods inherited from class java.lang.Object

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

Field Detail

throwExceptionWhenFlushing

static final AtomicBoolean throwExceptionWhenFlushing

conf

protected org.apache.hadoop.conf.Configuration conf

store

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

Constructor Detail

CustomStoreFlusher

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

Method Detail

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)
                                              throws IOException

Overrides:

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

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

createScanner

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

Throws:

IOException

performFlush

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

Throws:

IOException