public abstract class LoadTestDataGenerator extends Object
Modifier and Type | Field and Description |
---|---|
protected String[] |
args |
static byte[] |
INCREMENT |
protected LoadTestKVGenerator |
kvGenerator |
static byte[] |
MUTATE_INFO |
Constructor and Description |
---|
LoadTestDataGenerator() |
LoadTestDataGenerator(int minValueSize,
int maxValueSize)
Initializes the object.
|
Modifier and Type | Method and Description |
---|---|
Get |
beforeGet(long rowkeyBase,
Get get)
Giving a chance for the LoadTestDataGenerator to change the Get load.
|
Mutation |
beforeMutate(long rowkeyBase,
Mutation m)
Giving a chance for the LoadTestDataGenerator to change the Mutation load.
|
abstract byte[][] |
generateColumnsForCf(byte[] rowKey,
byte[] cf)
Generates an applicable set of columns to be used for a particular key and family.
|
abstract byte[] |
generateValue(byte[] rowKey,
byte[] cf,
byte[] column)
Generates a value to be used for a particular row/cf/column.
|
String[] |
getArgs()
Return the arguments passed to the generator as list of object
|
abstract byte[][] |
getColumnFamilies()
Gets column families for the load test table.
|
abstract byte[] |
getDeterministicUniqueKey(long keyBase)
Generates a deterministic, unique hashed row key from a number.
|
void |
initialize(String[] args)
initialize the LoadTestDataGenerator
|
abstract boolean |
verify(byte[] rowKey,
byte[] cf,
byte[] column,
byte[] value)
Checks that value for a rowKey/cf/column is valid if generated via
generateValue(byte[], byte[], byte[]) |
abstract boolean |
verify(byte[] rowKey,
byte[] cf,
Set<byte[]> columnSet)
Checks that columns for a rowKey and cf are valid if generated via
generateColumnsForCf(byte[], byte[]) |
protected LoadTestKVGenerator kvGenerator
public static final byte[] MUTATE_INFO
public static final byte[] INCREMENT
protected String[] args
public LoadTestDataGenerator()
public LoadTestDataGenerator(int minValueSize, int maxValueSize)
minValueSize
- minimum size of the value generated by
generateValue(byte[], byte[], byte[])
.maxValueSize
- maximum size of the value generated by
generateValue(byte[], byte[], byte[])
.public void initialize(String[] args)
args
- init argspublic abstract byte[] getDeterministicUniqueKey(long keyBase)
keyBase
- Base number for a key, such as a loop counter.public abstract byte[][] getColumnFamilies()
public abstract byte[][] generateColumnsForCf(byte[] rowKey, byte[] cf)
rowKey
- The row key to generate for.cf
- The column family name to generate for.public abstract byte[] generateValue(byte[] rowKey, byte[] cf, byte[] column)
rowKey
- The row key to generate for.cf
- The column family name to generate for.column
- The column name to generate for.public abstract boolean verify(byte[] rowKey, byte[] cf, Set<byte[]> columnSet)
generateColumnsForCf(byte[], byte[])
rowKey
- The row key to verify for.cf
- The column family name to verify for.columnSet
- The column set (for example, encountered by read).public abstract boolean verify(byte[] rowKey, byte[] cf, byte[] column, byte[] value)
generateValue(byte[], byte[], byte[])
rowKey
- The row key to verify for.cf
- The column family name to verify for.column
- The column name to verify for.value
- The value (for example, encountered by read).public Mutation beforeMutate(long rowkeyBase, Mutation m) throws IOException
rowkeyBase
- m
- IOException
public Get beforeGet(long rowkeyBase, Get get) throws IOException
rowkeyBase
- get
- IOException
public String[] getArgs()