public class ProcedureWALPerformanceEvaluation extends org.apache.hadoop.hbase.util.AbstractHBaseTool
Modifier and Type | Class and Description |
---|---|
private static class |
ProcedureWALPerformanceEvaluation.NoSyncWalProcedureStore |
private class |
ProcedureWALPerformanceEvaluation.Worker
Callable to generate load for wal by inserting/deleting/updating procedures.
|
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_NUM_PROCS |
static int |
DEFAULT_NUM_THREADS |
static int |
DEFAULT_NUM_WALS |
static int |
DEFAULT_STATE_SIZE |
static String |
DEFAULT_SYNC_OPTION |
static org.apache.hbase.thirdparty.org.apache.commons.cli.Option |
NUM_PROCS_OPTION |
static org.apache.hbase.thirdparty.org.apache.commons.cli.Option |
NUM_THREADS_OPTION |
static org.apache.hbase.thirdparty.org.apache.commons.cli.Option |
NUM_WALS_OPTION |
long |
numProcs |
long |
numProcsPerWal |
int |
numThreads |
int |
numWals |
private AtomicLong |
procIds
|
(package private) static byte[] |
serializedState |
static org.apache.hbase.thirdparty.org.apache.commons.cli.Option |
STATE_SIZE_OPTION |
int |
stateSize |
private org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore |
store |
static org.apache.hbase.thirdparty.org.apache.commons.cli.Option |
SYNC_OPTION |
String |
syncType |
protected static HBaseCommonTestingUtility |
UTIL |
private static int |
WORKER_THREADS_TIMEOUT_SEC |
private AtomicBoolean |
workersFailed |
Constructor and Description |
---|
ProcedureWALPerformanceEvaluation() |
Modifier and Type | Method and Description |
---|---|
void |
addOptions() |
int |
doWork() |
static void |
main(String[] args) |
void |
processOptions(org.apache.hbase.thirdparty.org.apache.commons.cli.CommandLine cmd)
Processes and validates command line options.
|
private void |
setupConf() |
private void |
setupProcedureStore() |
private void |
tearDownProcedureStore() |
addOption, addOptNoArg, addOptNoArg, addOptWithArg, addOptWithArg, addRequiredOption, addRequiredOptWithArg, addRequiredOptWithArg, doStaticMain, getConf, getOptionAsDouble, getOptionAsInt, getOptionAsLong, newParser, parseArgs, parseInt, parseLong, printUsage, printUsage, processOldArgs, run, setConf
protected static final HBaseCommonTestingUtility UTIL
public static int DEFAULT_NUM_THREADS
public static org.apache.hbase.thirdparty.org.apache.commons.cli.Option NUM_THREADS_OPTION
public static int DEFAULT_NUM_PROCS
public static org.apache.hbase.thirdparty.org.apache.commons.cli.Option NUM_PROCS_OPTION
public static int DEFAULT_NUM_WALS
public static org.apache.hbase.thirdparty.org.apache.commons.cli.Option NUM_WALS_OPTION
public static int DEFAULT_STATE_SIZE
public static org.apache.hbase.thirdparty.org.apache.commons.cli.Option STATE_SIZE_OPTION
public static org.apache.hbase.thirdparty.org.apache.commons.cli.Option SYNC_OPTION
public static String DEFAULT_SYNC_OPTION
public int numThreads
public long numProcs
public long numProcsPerWal
public int numWals
public int stateSize
static byte[] serializedState
private org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore store
private AtomicLong procIds
private AtomicBoolean workersFailed
private static final int WORKER_THREADS_TIMEOUT_SEC
public ProcedureWALPerformanceEvaluation()
private void setupConf()
private void setupProcedureStore() throws IOException
IOException
private void tearDownProcedureStore()
public void processOptions(org.apache.hbase.thirdparty.org.apache.commons.cli.CommandLine cmd)
processOptions
in class org.apache.hadoop.hbase.util.AbstractHBaseTool
public void addOptions()
addOptions
in class org.apache.hadoop.hbase.util.AbstractHBaseTool
public int doWork()
doWork
in class org.apache.hadoop.hbase.util.AbstractHBaseTool
public static void main(String[] args) throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.