org.apache.hadoop.hbase.mob

Class FaultyMobStoreCompactor

java.lang.Object

org.apache.hadoop.hbase.regionserver.compactions.Compactor<org.apache.hadoop.hbase.regionserver.StoreFileWriter>

org.apache.hadoop.hbase.regionserver.compactions.DefaultCompactor

org.apache.hadoop.hbase.mob.DefaultMobStoreCompactor

org.apache.hadoop.hbase.mob.FaultyMobStoreCompactor

@InterfaceAudience.Private
public class FaultyMobStoreCompactor
extends org.apache.hadoop.hbase.mob.DefaultMobStoreCompactor

This class is used for testing only. The main purpose is to emulate random failures during MOB compaction process. Example of usage:

 {
   @code
   public class SomeTest {

     public void initConfiguration(Configuration conf) {
       conf.set(MobStoreEngine.DEFAULT_MOB_COMPACTOR_CLASS_KEY,
         FaultyMobStoreCompactor.class.getName());
       conf.setDouble("hbase.mob.compaction.fault.probability", 0.1);
     }
   }
 }
 

See Also:

on how to use and configure this class.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.regionserver.compactions.Compactor

org.apache.hadoop.hbase.regionserver.compactions.Compactor.CellSinkFactory<S>, org.apache.hadoop.hbase.regionserver.compactions.Compactor.FileDetails, org.apache.hadoop.hbase.regionserver.compactions.Compactor.InternalScannerFactory

Field Summary

Fields

Modifier and Type	Field and Description
(package private) static double	failureProb
private static org.slf4j.Logger	LOG
static AtomicLong	mobCounter
(package private) static Random	rnd
static AtomicLong	totalCompactions
static AtomicLong	totalFailures
static AtomicLong	totalMajorCompactions

Fields inherited from class org.apache.hadoop.hbase.mob.DefaultMobStoreCompactor

disableIO, ioOptimizedMode, mobLengthMap, mobRefSet, mobSizeThreshold, mobStore, userRequest

Fields inherited from class org.apache.hadoop.hbase.regionserver.compactions.Compactor

COMPACTION_PROGRESS_LOG_INTERVAL, compactionKVMax, conf, defaultScannerFactory, dropCacheMajor, dropCacheMinor, keepSeqIdPeriod, MAJOR_COMPACTION_DROP_CACHE, majorCompactionCompression, MINOR_COMPACTION_DROP_CACHE, minorCompactionCompression, store

Constructor Summary

Constructors

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

Method Summary

Modifier and Type

Method and Description

protected boolean

performCompaction(org.apache.hadoop.hbase.regionserver.compactions.Compactor.FileDetails fd, org.apache.hadoop.hbase.regionserver.InternalScanner scanner, org.apache.hadoop.hbase.regionserver.CellSink writer, long smallestReadPoint, boolean cleanSeqId, org.apache.hadoop.hbase.regionserver.throttle.ThroughputController throughputController, org.apache.hadoop.hbase.regionserver.compactions.CompactionRequestImpl request, org.apache.hadoop.hbase.regionserver.compactions.CompactionProgress progress)

Methods inherited from class org.apache.hadoop.hbase.mob.DefaultMobStoreCompactor

commitWriter, compact, getStoreInfo, performCompaction

Methods inherited from class org.apache.hadoop.hbase.regionserver.compactions.DefaultCompactor

abortWriter

Methods inherited from class org.apache.hadoop.hbase.regionserver.compactions.Compactor

compact, createParams, createScanner, createScanner, createWriter, createWriter, getProgress, isCompacting

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

mobCounter

public static AtomicLong mobCounter

totalFailures

public static AtomicLong totalFailures

totalCompactions

public static AtomicLong totalCompactions

totalMajorCompactions

public static AtomicLong totalMajorCompactions

failureProb

static double failureProb

rnd

static Random rnd

Constructor Detail

FaultyMobStoreCompactor

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

Method Detail

performCompaction

protected boolean performCompaction(org.apache.hadoop.hbase.regionserver.compactions.Compactor.FileDetails fd,
                                    org.apache.hadoop.hbase.regionserver.InternalScanner scanner,
                                    org.apache.hadoop.hbase.regionserver.CellSink writer,
                                    long smallestReadPoint,
                                    boolean cleanSeqId,
                                    org.apache.hadoop.hbase.regionserver.throttle.ThroughputController throughputController,
                                    org.apache.hadoop.hbase.regionserver.compactions.CompactionRequestImpl request,
                                    org.apache.hadoop.hbase.regionserver.compactions.CompactionProgress progress)
                             throws IOException

Throws:

IOException