Package org.apache.hadoop.hbase.procedure2.store.wal

Class ProcedureWALLoaderPerformanceEvaluation

java.lang.Object

org.apache.hadoop.hbase.util.AbstractHBaseTool

org.apache.hadoop.hbase.procedure2.store.wal.ProcedureWALLoaderPerformanceEvaluation

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.util.Tool

public class ProcedureWALLoaderPerformanceEvaluation
extends org.apache.hadoop.hbase.util.AbstractHBaseTool

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	ProcedureWALLoaderPerformanceEvaluation.LoadCounter

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.util.AbstractHBaseTool

org.apache.hadoop.hbase.util.AbstractHBaseTool.OptionsOrderComparator

Field Summary

Fields

Modifier and Type	Field	Description
static double	DEFAULT_DELETE_PROCS_FRACTION
static int	DEFAULT_NUM_PROCS
static int	DEFAULT_NUM_WALS
static int	DEFAULT_STATE_SIZE
static int	DEFAULT_UPDATES_PER_PROC
static org.apache.hbase.thirdparty.org.apache.commons.cli.Option	DELETE_PROCS_FRACTION_OPTION
double	deleteProcsFraction
static org.apache.hbase.thirdparty.org.apache.commons.cli.Option	NUM_PROCS_OPTION
static org.apache.hbase.thirdparty.org.apache.commons.cli.Option	NUM_WALS_OPTION
int	numProcs
int	numWals
(package private) static byte[]	serializedState
static org.apache.hbase.thirdparty.org.apache.commons.cli.Option	STATE_SIZE_OPTION
private org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore	store
static org.apache.hbase.thirdparty.org.apache.commons.cli.Option	UPDATES_PER_PROC_OPTION
int	updatesPerProc
protected static final HBaseCommonTestingUtility	UTIL

Fields inherited from class org.apache.hadoop.hbase.util.AbstractHBaseTool

cmdLineArgs, conf, EXIT_FAILURE, EXIT_SUCCESS, LONG_HELP_OPTION, options, SHORT_HELP_OPTION

Constructor Summary

Constructors

Constructor	Description
ProcedureWALLoaderPerformanceEvaluation()

Method Summary

Modifier and Type	Method	Description
protected void	addOptions()
protected int	doWork()
static void	main(String[] args)
protected void	processOptions(org.apache.hbase.thirdparty.org.apache.commons.cli.CommandLine cmd)
private void	setupConf()
void	setUpProcedureStore()
private List<Integer>	shuffleProcWriteSequence()
private void	storeRestart(org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureLoader loader)
void	tearDownProcedureStore()
private void	writeWals()

Methods inherited from class org.apache.hadoop.hbase.util.AbstractHBaseTool

addOption, addOptNoArg, addOptNoArg, addOptWithArg, addOptWithArg, addRequiredOption, addRequiredOptWithArg, addRequiredOptWithArg, doStaticMain, getConf, getOptionAsDouble, getOptionAsInt, getOptionAsInt, getOptionAsLong, getOptionAsLong, newParser, parseArgs, parseInt, parseLong, printUsage, printUsage, processOldArgs, run, setConf

Methods inherited from class java.lang.Object

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

Field Details

UTIL

protected static final HBaseCommonTestingUtility UTIL

DEFAULT_NUM_PROCS

public static int DEFAULT_NUM_PROCS

NUM_PROCS_OPTION

public static org.apache.hbase.thirdparty.org.apache.commons.cli.Option NUM_PROCS_OPTION

DEFAULT_NUM_WALS

public static int DEFAULT_NUM_WALS

NUM_WALS_OPTION

public static org.apache.hbase.thirdparty.org.apache.commons.cli.Option NUM_WALS_OPTION

DEFAULT_STATE_SIZE

public static int DEFAULT_STATE_SIZE

STATE_SIZE_OPTION

public static org.apache.hbase.thirdparty.org.apache.commons.cli.Option STATE_SIZE_OPTION

DEFAULT_UPDATES_PER_PROC

public static int DEFAULT_UPDATES_PER_PROC

UPDATES_PER_PROC_OPTION

public static org.apache.hbase.thirdparty.org.apache.commons.cli.Option UPDATES_PER_PROC_OPTION

DEFAULT_DELETE_PROCS_FRACTION

public static double DEFAULT_DELETE_PROCS_FRACTION

DELETE_PROCS_FRACTION_OPTION

public static org.apache.hbase.thirdparty.org.apache.commons.cli.Option DELETE_PROCS_FRACTION_OPTION

numProcs

public int numProcs

updatesPerProc

public int updatesPerProc

deleteProcsFraction

public double deleteProcsFraction

numWals

public int numWals

store

private org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore store

serializedState

static byte[] serializedState

Constructor Details

ProcedureWALLoaderPerformanceEvaluation

public ProcedureWALLoaderPerformanceEvaluation()

Method Details

addOptions

protected void addOptions()

Specified by:

addOptions in class org.apache.hadoop.hbase.util.AbstractHBaseTool

processOptions

protected void processOptions(org.apache.hbase.thirdparty.org.apache.commons.cli.CommandLine cmd)

Specified by:

processOptions in class org.apache.hadoop.hbase.util.AbstractHBaseTool

setupConf

private void setupConf()

setUpProcedureStore

public void setUpProcedureStore()
                         throws IOException

Throws:

IOException

shuffleProcWriteSequence

private List<Integer> shuffleProcWriteSequence()

Returns:

a list of shuffled integers which represent state of proc id. First occurrence of a number denotes insert state, consecutive occurrences denote update states, and -ve value denotes delete state.

writeWals

private void writeWals()
                throws IOException

Throws:

IOException

storeRestart

private void storeRestart(org.apache.hadoop.hbase.procedure2.store.ProcedureStore.ProcedureLoader loader)
                   throws IOException

Throws:

IOException

tearDownProcedureStore

public void tearDownProcedureStore()

doWork

protected int doWork()

Specified by:

doWork in class org.apache.hadoop.hbase.util.AbstractHBaseTool

main

public static void main(String[] args)
                 throws IOException

Throws:

IOException