org.apache.hadoop.hbase.mapreduce

Class TestLoadIncrementalHFiles

java.lang.Object

org.apache.hadoop.hbase.mapreduce.TestLoadIncrementalHFiles

Direct Known Subclasses:

TestLoadIncrementalHFilesUseSecurityEndPoint, TestSecureLoadIncrementalHFiles

public class TestLoadIncrementalHFiles
extends Object

Test cases for the "load" half of the HFileOutputFormat bulk load functionality. These tests run faster than the full MR cluster tests in TestHFileOutputFormat

Field Summary

Fields

Modifier and Type	Field and Description
TestName	tn

Constructor Summary

Constructors

Constructor and Description
TestLoadIncrementalHFiles()

Method Summary

Modifier and Type	Method and Description
void	htestTagsSurviveBulkLoadSplit() Test that tags survive through a bulk load that needs to split hfiles.
static int	loadHFiles(String testName, HTableDescriptor htd, HBaseTestingUtility util, byte[] fam, byte[] qual, boolean preCreateTable, byte[][] tableSplitKeys, byte[][][] hfileRanges, boolean useMap, boolean deleteFile, boolean copyFiles, int initRowCount, int factor, boolean managed)
static void	setUpBeforeClass()
protected static void	setupNamespace()
static void	tearDownAfterClass()
void	testInferBoundaries()
void	testLoadTooMayHFiles()
void	testNonexistentColumnFamilyLoad() Test loading into a column family that does not exist.
void	testNonHfileFolder()
void	testNonHfileFolderWithUnmatchedFamilyName()
void	testRegionCrossingHFileSplit() Test case that creates some regions and loads HFiles that cross the boundaries and have different region boundaries than the table pre-split.
void	testRegionCrossingHFileSplitRowBloom() Test case that creates some regions and loads HFiles that cross the boundaries have a ROW bloom filter and a different region boundaries than the table pre-split.
void	testRegionCrossingHFileSplitRowColBloom() Test case that creates some regions and loads HFiles that cross the boundaries have a ROWCOL bloom filter and a different region boundaries than the table pre-split.
void	testRegionCrossingLoad() Test case that creates some regions and loads HFiles that cross the boundaries of those regions
void	testRegionCrossingRowBloom() Test loading into a column family that has a ROW bloom filter.
void	testRegionCrossingRowColBloom() Test loading into a column family that has a ROWCOL bloom filter.
void	testSimpleHFileSplit() Test case that creates some regions and loads HFiles that have different region boundaries than the table pre-split.
void	testSimpleLoad() Test case that creates some regions and loads HFiles that fit snugly inside those regions
void	testSimpleLoadWithFileCopy()
void	testSimpleLoadWithMap()
void	testSplitStoreFile()
void	testSplitStoreFileWithEncodedToEncoded()
void	testSplitStoreFileWithEncodedToNone()
void	testSplitStoreFileWithNoneToEncoded()
void	testSplitStoreFileWithNoneToNone()
void	testTableWithCFNameStartWithUnderScore()
void	testWithoutAnExistingTableAndCreateTableSetToNo()

Methods inherited from class java.lang.Object

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

Field Detail

tn

public TestName tn

Constructor Detail

TestLoadIncrementalHFiles

public TestLoadIncrementalHFiles()

Method Detail

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

setupNamespace

protected static void setupNamespace()
                              throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

testSimpleLoadWithMap

public void testSimpleLoadWithMap()
                           throws Exception

Throws:

Exception

testSimpleLoad

public void testSimpleLoad()
                    throws Exception

Test case that creates some regions and loads HFiles that fit snugly inside those regions

Throws:

Exception

testSimpleLoadWithFileCopy

public void testSimpleLoadWithFileCopy()
                                throws Exception

Throws:

Exception

testRegionCrossingLoad

public void testRegionCrossingLoad()
                            throws Exception

Test case that creates some regions and loads HFiles that cross the boundaries of those regions

Throws:

Exception

testRegionCrossingRowBloom

public void testRegionCrossingRowBloom()
                                throws Exception

Test loading into a column family that has a ROW bloom filter.

Throws:

Exception

testRegionCrossingRowColBloom

public void testRegionCrossingRowColBloom()
                                   throws Exception

Test loading into a column family that has a ROWCOL bloom filter.

Throws:

Exception

testSimpleHFileSplit

public void testSimpleHFileSplit()
                          throws Exception

Test case that creates some regions and loads HFiles that have different region boundaries than the table pre-split.

Throws:

Exception

testRegionCrossingHFileSplit

public void testRegionCrossingHFileSplit()
                                  throws Exception

Test case that creates some regions and loads HFiles that cross the boundaries and have different region boundaries than the table pre-split.

Throws:

Exception

testRegionCrossingHFileSplitRowBloom

public void testRegionCrossingHFileSplitRowBloom()
                                          throws Exception

Test case that creates some regions and loads HFiles that cross the boundaries have a ROW bloom filter and a different region boundaries than the table pre-split.

Throws:

Exception

testRegionCrossingHFileSplitRowColBloom

public void testRegionCrossingHFileSplitRowColBloom()
                                             throws Exception

Test case that creates some regions and loads HFiles that cross the boundaries have a ROWCOL bloom filter and a different region boundaries than the table pre-split.

Throws:

Exception

loadHFiles

public static int loadHFiles(String testName,
                             HTableDescriptor htd,
                             HBaseTestingUtility util,
                             byte[] fam,
                             byte[] qual,
                             boolean preCreateTable,
                             byte[][] tableSplitKeys,
                             byte[][][] hfileRanges,
                             boolean useMap,
                             boolean deleteFile,
                             boolean copyFiles,
                             int initRowCount,
                             int factor,
                             boolean managed)
                      throws Exception

Throws:

Exception

htestTagsSurviveBulkLoadSplit

public void htestTagsSurviveBulkLoadSplit()
                                   throws Exception

Test that tags survive through a bulk load that needs to split hfiles. This test depends on the "hbase.client.rpc.codec" = KeyValueCodecWithTags so that the client can get tags in the responses.

Throws:

Exception

testNonexistentColumnFamilyLoad

public void testNonexistentColumnFamilyLoad()
                                     throws Exception

Test loading into a column family that does not exist.

Throws:

Exception

testNonHfileFolderWithUnmatchedFamilyName

public void testNonHfileFolderWithUnmatchedFamilyName()
                                               throws Exception

Throws:

Exception

testNonHfileFolder

public void testNonHfileFolder()
                        throws Exception

Throws:

Exception

testSplitStoreFile

public void testSplitStoreFile()
                        throws IOException

Throws:

IOException

testSplitStoreFileWithNoneToNone

public void testSplitStoreFileWithNoneToNone()
                                      throws IOException

Throws:

IOException

testSplitStoreFileWithEncodedToEncoded

public void testSplitStoreFileWithEncodedToEncoded()
                                            throws IOException

Throws:

IOException

testSplitStoreFileWithEncodedToNone

public void testSplitStoreFileWithEncodedToNone()
                                         throws IOException

Throws:

IOException

testSplitStoreFileWithNoneToEncoded

public void testSplitStoreFileWithNoneToEncoded()
                                         throws IOException

Throws:

IOException

testInferBoundaries

public void testInferBoundaries()

testLoadTooMayHFiles

public void testLoadTooMayHFiles()
                          throws Exception

Throws:

Exception

testWithoutAnExistingTableAndCreateTableSetToNo

public void testWithoutAnExistingTableAndCreateTableSetToNo()
                                                     throws Exception

Throws:

Exception

testTableWithCFNameStartWithUnderScore

public void testTableWithCFNameStartWithUnderScore()
                                            throws Exception

Throws:

Exception