org.apache.hadoop.hbase.regionserver

Class TestSecureBulkloadListener

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestSecureBulkloadListener

public class TestSecureBulkloadListener
extends Object

Tests for failedBulkLoad logic to make sure staged files are returned to their original location if the bulkload have failed.

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private org.apache.hadoop.hdfs.MiniDFSCluster	cluster
private org.apache.hadoop.conf.Configuration	conf
private static String	CUSTOM_STAGING_DIR
private org.apache.hadoop.hdfs.DistributedFileSystem	dfs
private static byte[]	FAMILY
private static String	host1
private static String	host2
private static String	host3
private HBaseTestingUtility	htu
org.junit.rules.TestName	name
private Random	random
private byte[]	randomBytes
private static String	STAGING_DIR
static org.junit.rules.TemporaryFolder	testFolder

Constructor Summary

Constructors

Constructor and Description
TestSecureBulkloadListener()

Method Summary

Modifier and Type	Method and Description
private String	createHFileForFamilies(byte[] family)
private static String	generateUniqueName(String suffix)
void	setUp()
void	tearDownAfterClass()
void	testCopiedStagedFile()
void	testDeletedStagedFile()
void	testMovingStagedFile()
void	testMovingStagedFileWithCustomStageDir()

Methods inherited from class java.lang.Object

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

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

testFolder

public static org.junit.rules.TemporaryFolder testFolder

conf

private org.apache.hadoop.conf.Configuration conf

cluster

private org.apache.hadoop.hdfs.MiniDFSCluster cluster

htu

private HBaseTestingUtility htu

dfs

private org.apache.hadoop.hdfs.DistributedFileSystem dfs

random

private final Random random

randomBytes

private final byte[] randomBytes

host1

private static final String host1

See Also:

Constant Field Values

host2

private static final String host2

See Also:

Constant Field Values

host3

private static final String host3

See Also:

Constant Field Values

FAMILY

private static byte[] FAMILY

STAGING_DIR

private static final String STAGING_DIR

See Also:

Constant Field Values

CUSTOM_STAGING_DIR

private static final String CUSTOM_STAGING_DIR

See Also:

Constant Field Values

name

public org.junit.rules.TestName name

Constructor Detail

TestSecureBulkloadListener

public TestSecureBulkloadListener()

Method Detail

setUp

public void setUp()
           throws Exception

Throws:

Exception

tearDownAfterClass

public void tearDownAfterClass()
                        throws Exception

Throws:

Exception

testMovingStagedFile

public void testMovingStagedFile()
                          throws Exception

Throws:

Exception

testMovingStagedFileWithCustomStageDir

public void testMovingStagedFileWithCustomStageDir()
                                            throws Exception

Throws:

Exception

testCopiedStagedFile

public void testCopiedStagedFile()
                          throws Exception

Throws:

Exception

testDeletedStagedFile

public void testDeletedStagedFile()
                           throws Exception

Throws:

Exception

createHFileForFamilies

private String createHFileForFamilies(byte[] family)
                               throws IOException

Throws:

IOException

generateUniqueName

private static String generateUniqueName(String suffix)