Package org.apache.hadoop.hbase

Class HFilePerformanceEvaluation

java.lang.Object

org.apache.hadoop.hbase.HFilePerformanceEvaluation

@LimitedPrivate("Tools")
public class HFilePerformanceEvaluation
extends Object

This class runs performance benchmarks for HFile.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	HFilePerformanceEvaluation.GaussianRandomReadBenchmark
(package private) static class	HFilePerformanceEvaluation.ReadBenchmark
(package private) static class	HFilePerformanceEvaluation.RowOrientedBenchmark
(package private) static class	HFilePerformanceEvaluation.SequentialReadBenchmark
(package private) static class	HFilePerformanceEvaluation.SequentialWriteBenchmark
(package private) static class	HFilePerformanceEvaluation.UniformRandomReadBenchmark
(package private) static class	HFilePerformanceEvaluation.UniformRandomSmallScan

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG
private static final int	RFILE_BLOCKSIZE
private static final int	ROW_COUNT
private static final int	ROW_LENGTH
private static StringBuilder	testSummary

Constructor Summary

Constructors

Constructor	Description
HFilePerformanceEvaluation()

Method Summary

Modifier and Type	Method	Description
(package private) static ExtendedCell	createCell(byte[] keyRow)
(package private) static ExtendedCell	createCell(byte[] keyRow, byte[] value)
(package private) static ExtendedCell	createCell(int i)
(package private) static ExtendedCell	createCell(int i, byte[] value)	HFile is Cell-based.
(package private) static byte[]	format(int i)
(package private) static ImmutableBytesWritable	format(int i, ImmutableBytesWritable w)
private String	getCipherName(org.apache.hadoop.conf.Configuration conf, String cipherName)
static void	main(String[] args)
protected void	runBenchmark(HFilePerformanceEvaluation.RowOrientedBenchmark benchmark, int rowCount, String codec, String cipher)
private void	runBenchmarks()	Add any supported codec or cipher to test the HFile read/write performance.
private void	runReadBenchmark(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path mf, String codec, String cipher)	Run all the read benchmarks for the test HFile
private void	runWriteBenchmark(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path mf, String codec, String cipher)	Write a test HFile with the given codec & cipher

Methods inherited from class java.lang.Object

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

Field Details

ROW_LENGTH

private static final int ROW_LENGTH

See Also:

• Constant Field Values

ROW_COUNT

private static final int ROW_COUNT

See Also:

• Constant Field Values

RFILE_BLOCKSIZE

private static final int RFILE_BLOCKSIZE

See Also:

• Constant Field Values

testSummary

private static StringBuilder testSummary

LOG

private static final org.slf4j.Logger LOG

Constructor Details

HFilePerformanceEvaluation

public HFilePerformanceEvaluation()

Method Details

format

static byte[] format(int i)

format

static ImmutableBytesWritable format(int i,
 ImmutableBytesWritable w)

createCell

static ExtendedCell createCell(int i)

createCell

static ExtendedCell createCell(int i,
 byte[] value)

HFile is Cell-based. It used to be byte arrays. Doing this test, pass Cells. All Cells intentionally have same coordinates in all fields but row.

Parameters:

i - Integer to format as a row Key.

value - Value to use

Returns:

Created Cell.

createCell

static ExtendedCell createCell(byte[] keyRow)

createCell

static ExtendedCell createCell(byte[] keyRow,
 byte[] value)

runBenchmarks

private void runBenchmarks()
                    throws Exception

Add any supported codec or cipher to test the HFile read/write performance. Specify "none" to disable codec or cipher or both.

Throws:

Exception

runWriteBenchmark

private void runWriteBenchmark(org.apache.hadoop.conf.Configuration conf,
 org.apache.hadoop.fs.FileSystem fs,
 org.apache.hadoop.fs.Path mf,
 String codec,
 String cipher)
                        throws Exception

Write a test HFile with the given codec & cipher

Parameters:

codec - "none", "lzo", "gz", "snappy"

cipher - "none", "aes"

Throws:

Exception

runReadBenchmark

private void runReadBenchmark(org.apache.hadoop.conf.Configuration conf,
 org.apache.hadoop.fs.FileSystem fs,
 org.apache.hadoop.fs.Path mf,
 String codec,
 String cipher)

Run all the read benchmarks for the test HFile

Parameters:

codec - "none", "lzo", "gz", "snappy"

cipher - "none", "aes"

runBenchmark

protected void runBenchmark(HFilePerformanceEvaluation.RowOrientedBenchmark benchmark,
 int rowCount,
 String codec,
 String cipher)
                     throws Exception

Throws:

Exception

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

getCipherName

private String getCipherName(org.apache.hadoop.conf.Configuration conf,
 String cipherName)