Package org.apache.hadoop.hbase.util

Class LoadTestUtil

java.lang.Object

org.apache.hadoop.hbase.util.LoadTestUtil

@Private
public class LoadTestUtil
extends Object

This class was created by moving all load test related code from HFileTestUtil and HBaseTestingUtil as part of refactoring for hbase-diagnostics module creation in HBASE-28432

Field Summary

Fields

Modifier and Type	Field	Description
private static final int	DEFAULT_REGIONS_PER_SERVER	The default number of regions per regionserver when creating a pre-split table.
private static final org.slf4j.Logger	LOG
static final String	OPT_DATA_BLOCK_ENCODING
static final String	OPT_DATA_BLOCK_ENCODING_USAGE

Constructor Summary

Constructors

Constructor	Description
LoadTestUtil()

Method Summary

Modifier and Type	Method	Description
static int	createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf, TableDescriptor desc, ColumnFamilyDescriptor hcd)	Creates a pre-split table for load testing.
static int	createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf, TableDescriptor desc, ColumnFamilyDescriptor[] hcds, int numRegionsPerServer)	Creates a pre-split table for load testing.
static int	createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf, TableDescriptor td, ColumnFamilyDescriptor[] cds, RegionSplitter.SplitAlgorithm splitter, int numRegionsPerServer)	Creates a pre-split table for load testing.
static int	createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf, TableDescriptor desc, ColumnFamilyDescriptor hcd, int numRegionsPerServer)	Creates a pre-split table for load testing.
static int	createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf, TableName tableName, byte[][] columnFamilies, Compression.Algorithm compression, DataBlockEncoding dataBlockEncoding, int numRegionsPerServer, int regionReplication, Durability durability)	Creates a pre-split table for load testing.
static int	createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf, TableName tableName, byte[] columnFamily, Compression.Algorithm compression, DataBlockEncoding dataBlockEncoding)	Creates a pre-split table for load testing.
static int	createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf, TableName tableName, byte[] columnFamily, Compression.Algorithm compression, DataBlockEncoding dataBlockEncoding, int numRegionsPerServer, int regionReplication, Durability durability)	Creates a pre-split table for load testing.

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

OPT_DATA_BLOCK_ENCODING_USAGE

public static final String OPT_DATA_BLOCK_ENCODING_USAGE

OPT_DATA_BLOCK_ENCODING

public static final String OPT_DATA_BLOCK_ENCODING

DEFAULT_REGIONS_PER_SERVER

private static final int DEFAULT_REGIONS_PER_SERVER

The default number of regions per regionserver when creating a pre-split table.

See Also:

• Constant Field Values

Constructor Details

LoadTestUtil

public LoadTestUtil()

Method Details

createPreSplitLoadTestTable

public static int createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf,
 TableName tableName,
 byte[] columnFamily,
 Compression.Algorithm compression,
 DataBlockEncoding dataBlockEncoding)
                                       throws IOException

Creates a pre-split table for load testing. If the table already exists, logs a warning and continues.

Returns:

the number of regions the table was split into

Throws:

IOException

createPreSplitLoadTestTable

public static int createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf,
 TableName tableName,
 byte[] columnFamily,
 Compression.Algorithm compression,
 DataBlockEncoding dataBlockEncoding,
 int numRegionsPerServer,
 int regionReplication,
 Durability durability)
                                       throws IOException

Creates a pre-split table for load testing. If the table already exists, logs a warning and continues.

Returns:

the number of regions the table was split into

Throws:

IOException

createPreSplitLoadTestTable

public static int createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf,
 TableName tableName,
 byte[][] columnFamilies,
 Compression.Algorithm compression,
 DataBlockEncoding dataBlockEncoding,
 int numRegionsPerServer,
 int regionReplication,
 Durability durability)
                                       throws IOException

Creates a pre-split table for load testing. If the table already exists, logs a warning and continues.

Returns:

the number of regions the table was split into

Throws:

IOException

createPreSplitLoadTestTable

public static int createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf,
 TableDescriptor desc,
 ColumnFamilyDescriptor hcd)
                                       throws IOException

Creates a pre-split table for load testing. If the table already exists, logs a warning and continues.

Returns:

the number of regions the table was split into

Throws:

IOException

createPreSplitLoadTestTable

public static int createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf,
 TableDescriptor desc,
 ColumnFamilyDescriptor hcd,
 int numRegionsPerServer)
                                       throws IOException

Creates a pre-split table for load testing. If the table already exists, logs a warning and continues.

Returns:

the number of regions the table was split into

Throws:

IOException

createPreSplitLoadTestTable

public static int createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf,
 TableDescriptor desc,
 ColumnFamilyDescriptor[] hcds,
 int numRegionsPerServer)
                                       throws IOException

Creates a pre-split table for load testing. If the table already exists, logs a warning and continues.

Returns:

the number of regions the table was split into

Throws:

IOException

createPreSplitLoadTestTable

public static int createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf,
 TableDescriptor td,
 ColumnFamilyDescriptor[] cds,
 RegionSplitter.SplitAlgorithm splitter,
 int numRegionsPerServer)
                                       throws IOException

Creates a pre-split table for load testing. If the table already exists, logs a warning and continues.

Returns:

the number of regions the table was split into

Throws:

IOException