Package org.apache.hadoop.hbase

Class IntegrationTestLazyCfLoading.DataGenerator

java.lang.Object

org.apache.hadoop.hbase.util.test.LoadTestDataGenerator

org.apache.hadoop.hbase.IntegrationTestLazyCfLoading.DataGenerator

Enclosing class:

IntegrationTestLazyCfLoading

private static class IntegrationTestLazyCfLoading.DataGenerator
extends org.apache.hadoop.hbase.util.test.LoadTestDataGenerator

Custom LoadTestDataGenerator. Uses key generation and verification from LoadTestKVGenerator. Creates 3 column families; one with an integer column to filter on, the 2nd one with an integer column that matches the first integer column (for test-specific verification), and byte[] value that is used for general verification; and the third one with just the value.

Field Summary

Fields

Modifier and Type	Field	Description
static final long	ACCEPTED_VALUE
private static final Map<byte[],byte[][]>	columnMap
static final byte[]	ESSENTIAL_CF
private final AtomicLong	expectedNumberOfKeys
static final byte[]	FILTER_COLUMN
static final byte[]	JOINED_CF1
static final byte[]	JOINED_CF2
private static final int	MAX_DATA_SIZE
private static final int	MIN_DATA_SIZE
private final AtomicLong	totalNumberOfKeys
static final byte[]	VALUE_COLUMN

Fields inherited from class org.apache.hadoop.hbase.util.test.LoadTestDataGenerator

args, INCREMENT, kvGenerator, MUTATE_INFO

Constructor Summary

Constructors

Constructor	Description
DataGenerator()

Method Summary

Modifier and Type	Method	Description
byte[][]	generateColumnsForCf(byte[] rowKey, byte[] cf)
byte[]	generateValue(byte[] rowKey, byte[] cf, byte[] column)
byte[][]	getColumnFamilies()
byte[]	getDeterministicUniqueKey(long keyBase)
long	getExpectedNumberOfKeys()
org.apache.hadoop.hbase.filter.Filter	getScanFilter()
long	getTotalNumberOfKeys()
boolean	verify(byte[] rowKey, byte[] cf, byte[] column, byte[] value)
boolean	verify(byte[] rowKey, byte[] cf, Set<byte[]> columnSet)

Methods inherited from class org.apache.hadoop.hbase.util.test.LoadTestDataGenerator

beforeGet, beforeMutate, generateData, getArgs, initialize

Methods inherited from class java.lang.Object

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

Field Details

MIN_DATA_SIZE

private static final int MIN_DATA_SIZE

See Also:

• Constant Field Values

MAX_DATA_SIZE

private static final int MAX_DATA_SIZE

See Also:

• Constant Field Values

ESSENTIAL_CF

public static final byte[] ESSENTIAL_CF

JOINED_CF1

public static final byte[] JOINED_CF1

JOINED_CF2

public static final byte[] JOINED_CF2

FILTER_COLUMN

public static final byte[] FILTER_COLUMN

VALUE_COLUMN

public static final byte[] VALUE_COLUMN

ACCEPTED_VALUE

public static final long ACCEPTED_VALUE

See Also:

• Constant Field Values

columnMap

private static final Map<byte[],byte[][]> columnMap

expectedNumberOfKeys

private final AtomicLong expectedNumberOfKeys

totalNumberOfKeys

private final AtomicLong totalNumberOfKeys

Constructor Details

DataGenerator

public DataGenerator()

Method Details

getExpectedNumberOfKeys

public long getExpectedNumberOfKeys()

getTotalNumberOfKeys

public long getTotalNumberOfKeys()

getDeterministicUniqueKey

public byte[] getDeterministicUniqueKey(long keyBase)

Specified by:

getDeterministicUniqueKey in class org.apache.hadoop.hbase.util.test.LoadTestDataGenerator

getColumnFamilies

public byte[][] getColumnFamilies()

Specified by:

getColumnFamilies in class org.apache.hadoop.hbase.util.test.LoadTestDataGenerator

generateColumnsForCf

public byte[][] generateColumnsForCf(byte[] rowKey,
 byte[] cf)

Specified by:

generateColumnsForCf in class org.apache.hadoop.hbase.util.test.LoadTestDataGenerator

generateValue

public byte[] generateValue(byte[] rowKey,
 byte[] cf,
 byte[] column)

Specified by:

generateValue in class org.apache.hadoop.hbase.util.test.LoadTestDataGenerator

verify

public boolean verify(byte[] rowKey,
 byte[] cf,
 byte[] column,
 byte[] value)

Specified by:

verify in class org.apache.hadoop.hbase.util.test.LoadTestDataGenerator

verify

public boolean verify(byte[] rowKey,
 byte[] cf,
 Set<byte[]> columnSet)

Specified by:

verify in class org.apache.hadoop.hbase.util.test.LoadTestDataGenerator

getScanFilter

public org.apache.hadoop.hbase.filter.Filter getScanFilter()