org.apache.hadoop.hbase.regionserver

Class TestHRegionServerBulkLoad

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestHRegionServerBulkLoad

public class TestHRegionServerBulkLoad
extends Object

Tests bulk loading of HFiles and shows the atomicity or lack of atomicity of the region server's bullkLoad functionality.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestHRegionServerBulkLoad.AtomicHFileLoader Thread that does full scans of the table looking for any partially completed rows.
static class	TestHRegionServerBulkLoad.AtomicScanReader Thread that does full scans of the table looking for any partially completed rows.
static class	TestHRegionServerBulkLoad.MyObserver

Field Summary

Fields

Modifier and Type	Field and Description
static int	BLOCKSIZE
static Compression.Algorithm	COMPRESSION

Constructor Summary

Constructors

Constructor and Description
TestHRegionServerBulkLoad(int duration)

Method Summary

Modifier and Type	Method and Description
static void	createHFile(FileSystem fs, Path path, byte[] family, byte[] qualifier, byte[] value, int numRows) Create an HFile with the given number of rows with a specified value.
static void	main(String[] args) Run test on an HBase instance for 5 minutes.
static Collection<Object[]>	parameters()
static byte[]	rowkey(int i) Create a rowkey compatible with createHFile(FileSystem, Path, byte[], byte[], byte[], int).
static void	setUpBeforeClass()
void	testAtomicBulkLoad() Atomic bulk load.

Methods inherited from class java.lang.Object

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

Field Detail

BLOCKSIZE

public static int BLOCKSIZE

COMPRESSION

public static Compression.Algorithm COMPRESSION

Constructor Detail

TestHRegionServerBulkLoad

public TestHRegionServerBulkLoad(int duration)

Method Detail

parameters

public static final Collection<Object[]> parameters()

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

rowkey

public static byte[] rowkey(int i)

Create a rowkey compatible with createHFile(FileSystem, Path, byte[], byte[], byte[], int).

createHFile

public static void createHFile(FileSystem fs,
                               Path path,
                               byte[] family,
                               byte[] qualifier,
                               byte[] value,
                               int numRows)
                        throws IOException

Create an HFile with the given number of rows with a specified value.

Throws:

IOException

testAtomicBulkLoad

public void testAtomicBulkLoad()
                        throws Exception

Atomic bulk load.

Throws:

Exception

main

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

Run test on an HBase instance for 5 minutes. This assumes that the table under test only has a single region.

Throws:

Exception