Package org.apache.hadoop.hbase

Class PerformanceEvaluation.TestOptions

java.lang.Object

org.apache.hadoop.hbase.PerformanceEvaluation.TestOptions

Enclosing class:

PerformanceEvaluation

static class PerformanceEvaluation.TestOptions
extends Object

Wraps up options passed to PerformanceEvaluation. This makes tracking all these arguments a little easier. NOTE: ADDING AN OPTION, you need to add a data member, a getter/setter (to make JSON serialization of this TestOptions class behave), and you need to add to the clone constructor below copying your new option from the 'that' to the 'this'. Look for 'clone' below.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) boolean	addColumns
(package private) boolean	asyncPrefetch
(package private) boolean	autoFlush
(package private) DataBlockEncoding	blockEncoding
(package private) int	blockSize
(package private) BloomType	bloomType
(package private) long	bufferSize
(package private) boolean	cacheBlocks
(package private) int	caching
(package private) String	cmdName
(package private) int	columns
(package private) Properties	commandProperties
(package private) Compression.Algorithm	compression
(package private) int	connCount
(package private) int	cycles
(package private) String	encryption
(package private) int	families
(package private) boolean	filterAll
(package private) boolean	flushCommits
(package private) boolean	inMemoryCF
(package private) MemoryCompactionPolicy	inMemoryCompaction
(package private) int	latencyThreshold
(package private) int	measureAfter
(package private) int	multiGet
(package private) int	multiPut
(package private) boolean	nomapred
(package private) int	noOfTags
(package private) int	numClientThreads
(package private) boolean	oneCon
(package private) int	perClientRunRows
(package private) int	period
(package private) int	presplitRegions
(package private) int	randomSleep
(package private) int	replicas
(package private) boolean	reportLatency
(package private) float	sampleRate
(package private) Scan.ReadType	scanReadType
(package private) float	size
(package private) String	splitPolicy
(package private) int	startRow
(package private) String	tableName
(package private) int	totalRows
(package private) double	traceRate	Deprecated. Useless after switching to OpenTelemetry
(package private) boolean	useTags
(package private) boolean	valueRandom
(package private) int	valueSize
(package private) boolean	valueZipf
(package private) boolean	writeToWAL

Constructor Summary

Constructors

Constructor	Description
TestOptions()
TestOptions(PerformanceEvaluation.TestOptions that)	Clone constructor.

Method Summary

Modifier and Type	Method	Description
boolean	getAddColumns()
DataBlockEncoding	getBlockEncoding()
int	getBlockSize()
BloomType	getBloomType()
long	getBufferSize()
int	getCaching()
String	getCmdName()
int	getColumns()
Properties	getCommandProperties()
Compression.Algorithm	getCompression()
int	getConnCount()
int	getCycles()
String	getEncryption()
int	getFamilies()
MemoryCompactionPolicy	getInMemoryCompaction()
int	getMeasureAfter()
int	getMultiGet()
int	getMultiPut()
int	getNoOfTags()
int	getNumClientThreads()
int	getPerClientRunRows()
int	getPeriod()
int	getPresplitRegions()
int	getRandomSleep()
int	getReplicas()
float	getSampleRate()
float	getSize()
String	getSplitPolicy()
int	getStartRow()
String	getTableName()
int	getTotalRows()
double	getTraceRate()
int	getValueSize()
boolean	isAutoFlush()
boolean	isFilterAll()
boolean	isFlushCommits()
boolean	isInMemoryCF()
boolean	isNomapred()
boolean	isOneCon()
boolean	isReportLatency()
boolean	isUseTags()
boolean	isValueRandom()
boolean	isValueZipf()
boolean	isWriteToWAL()
void	setAddColumns(boolean addColumns)
void	setAutoFlush(boolean autoFlush)
void	setBlockEncoding(DataBlockEncoding blockEncoding)
void	setBlockSize(int blockSize)
void	setBloomType(BloomType bloomType)
void	setBufferSize(long bufferSize)
void	setCaching(int caching)
void	setCmdName(String cmdName)
void	setColumns(int columns)
void	setCompression(Compression.Algorithm compression)
void	setConnCount(int connCount)
void	setCycles(int cycles)
void	setEncryption(String encryption)
void	setFamilies(int families)
void	setFilterAll(boolean filterAll)
void	setFlushCommits(boolean flushCommits)
void	setInMemoryCF(boolean inMemoryCF)
void	setInMemoryCompaction(MemoryCompactionPolicy inMemoryCompaction)
void	setMeasureAfter(int measureAfter)
void	setMultiGet(int multiGet)
void	setMultiPut(int multiPut)
void	setNomapred(boolean nomapred)
void	setNoOfTags(int noOfTags)
void	setNumClientThreads(int numClientThreads)
void	setOneCon(boolean oneCon)
void	setPerClientRunRows(int perClientRunRows)
void	setPeriod(int period)
void	setPresplitRegions(int presplitRegions)
void	setRandomSleep(int randomSleep)
void	setReplicas(int replicas)
void	setReportLatency(boolean reportLatency)
void	setSampleRate(float sampleRate)
void	setSize(float size)
void	setSplitPolicy(String splitPolicy)
void	setStartRow(int startRow)
void	setTableName(String tableName)
void	setTotalRows(int totalRows)
void	setTraceRate(double traceRate)
void	setUseTags(boolean useTags)
void	setValueRandom(boolean valueRandom)
void	setValueSize(int valueSize)
void	setValueZipf(boolean valueZipf)
void	setWriteToWAL(boolean writeToWAL)

Methods inherited from class java.lang.Object

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

Field Details

cmdName

String cmdName

nomapred

boolean nomapred

filterAll

boolean filterAll

startRow

int startRow

size

float size

perClientRunRows

int perClientRunRows

numClientThreads

int numClientThreads

totalRows

int totalRows

measureAfter

int measureAfter

sampleRate

float sampleRate

traceRate

@Deprecated
double traceRate

Deprecated.

Useless after switching to OpenTelemetry

tableName

String tableName

flushCommits

boolean flushCommits

writeToWAL

boolean writeToWAL

autoFlush

boolean autoFlush

oneCon

boolean oneCon

connCount

int connCount

useTags

boolean useTags

noOfTags

int noOfTags

reportLatency

boolean reportLatency

multiGet

int multiGet

multiPut

int multiPut

randomSleep

int randomSleep

inMemoryCF

boolean inMemoryCF

presplitRegions

int presplitRegions

replicas

int replicas

splitPolicy

String splitPolicy

compression

Compression.Algorithm compression

encryption

String encryption

bloomType

BloomType bloomType

blockSize

int blockSize

blockEncoding

DataBlockEncoding blockEncoding

valueRandom

boolean valueRandom

valueZipf

boolean valueZipf

valueSize

int valueSize

period

int period

cycles

int cycles

columns

int columns

families

int families

caching

int caching

latencyThreshold

int latencyThreshold

addColumns

boolean addColumns

inMemoryCompaction

MemoryCompactionPolicy inMemoryCompaction

asyncPrefetch

boolean asyncPrefetch

cacheBlocks

boolean cacheBlocks

scanReadType

Scan.ReadType scanReadType

bufferSize

long bufferSize

commandProperties

Properties commandProperties

Constructor Details

TestOptions

public TestOptions()

TestOptions

public TestOptions(PerformanceEvaluation.TestOptions that)

Clone constructor.

Parameters:

that - Object to copy from.

Method Details

getCommandProperties

public Properties getCommandProperties()

getCaching

public int getCaching()

setCaching

public void setCaching(int caching)

getColumns

public int getColumns()

setColumns

public void setColumns(int columns)

getFamilies

public int getFamilies()

setFamilies

public void setFamilies(int families)

getCycles

public int getCycles()

setCycles

public void setCycles(int cycles)

isValueZipf

public boolean isValueZipf()

setValueZipf

public void setValueZipf(boolean valueZipf)

getCmdName

public String getCmdName()

setCmdName

public void setCmdName(String cmdName)

getRandomSleep

public int getRandomSleep()

setRandomSleep

public void setRandomSleep(int randomSleep)

getReplicas

public int getReplicas()

setReplicas

public void setReplicas(int replicas)

getSplitPolicy

public String getSplitPolicy()

setSplitPolicy

public void setSplitPolicy(String splitPolicy)

setNomapred

public void setNomapred(boolean nomapred)

setFilterAll

public void setFilterAll(boolean filterAll)

setStartRow

public void setStartRow(int startRow)

setSize

public void setSize(float size)

setPerClientRunRows

public void setPerClientRunRows(int perClientRunRows)

setNumClientThreads

public void setNumClientThreads(int numClientThreads)

setTotalRows

public void setTotalRows(int totalRows)

setSampleRate

public void setSampleRate(float sampleRate)

setTraceRate

public void setTraceRate(double traceRate)

setTableName

public void setTableName(String tableName)

setFlushCommits

public void setFlushCommits(boolean flushCommits)

setWriteToWAL

public void setWriteToWAL(boolean writeToWAL)

setAutoFlush

public void setAutoFlush(boolean autoFlush)

setOneCon

public void setOneCon(boolean oneCon)

getConnCount

public int getConnCount()

setConnCount

public void setConnCount(int connCount)

setUseTags

public void setUseTags(boolean useTags)

setNoOfTags

public void setNoOfTags(int noOfTags)

setReportLatency

public void setReportLatency(boolean reportLatency)

setMultiGet

public void setMultiGet(int multiGet)

setMultiPut

public void setMultiPut(int multiPut)

setInMemoryCF

public void setInMemoryCF(boolean inMemoryCF)

setPresplitRegions

public void setPresplitRegions(int presplitRegions)

setCompression

public void setCompression(Compression.Algorithm compression)

setEncryption

public void setEncryption(String encryption)

setBloomType

public void setBloomType(BloomType bloomType)

setBlockSize

public void setBlockSize(int blockSize)

setBlockEncoding

public void setBlockEncoding(DataBlockEncoding blockEncoding)

setValueRandom

public void setValueRandom(boolean valueRandom)

setValueSize

public void setValueSize(int valueSize)

setBufferSize

public void setBufferSize(long bufferSize)

setPeriod

public void setPeriod(int period)

isNomapred

public boolean isNomapred()

isFilterAll

public boolean isFilterAll()

getStartRow

public int getStartRow()

getSize

public float getSize()

getPerClientRunRows

public int getPerClientRunRows()

getNumClientThreads

public int getNumClientThreads()

getTotalRows

public int getTotalRows()

getSampleRate

public float getSampleRate()

getTraceRate

public double getTraceRate()

getTableName

public String getTableName()

isFlushCommits

public boolean isFlushCommits()

isWriteToWAL

public boolean isWriteToWAL()

isAutoFlush

public boolean isAutoFlush()

isUseTags

public boolean isUseTags()

getNoOfTags

public int getNoOfTags()

isReportLatency

public boolean isReportLatency()

getMultiGet

public int getMultiGet()

getMultiPut

public int getMultiPut()

isInMemoryCF

public boolean isInMemoryCF()

getPresplitRegions

public int getPresplitRegions()

getCompression

public Compression.Algorithm getCompression()

getEncryption

public String getEncryption()

getBlockEncoding

public DataBlockEncoding getBlockEncoding()

isValueRandom

public boolean isValueRandom()

getValueSize

public int getValueSize()

getPeriod

public int getPeriod()

getBloomType

public BloomType getBloomType()

getBlockSize

public int getBlockSize()

isOneCon

public boolean isOneCon()

getMeasureAfter

public int getMeasureAfter()

setMeasureAfter

public void setMeasureAfter(int measureAfter)

getAddColumns

public boolean getAddColumns()

setAddColumns

public void setAddColumns(boolean addColumns)

setInMemoryCompaction

public void setInMemoryCompaction(MemoryCompactionPolicy inMemoryCompaction)

getInMemoryCompaction

public MemoryCompactionPolicy getInMemoryCompaction()

getBufferSize

public long getBufferSize()