Package org.apache.hadoop.hbase.regionserver

Class TestSecureBulkloadListener

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestSecureBulkloadListener

@Tag("org.apache.hadoop.hbase.testclassification.MiscTests") @Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
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	Description
private org.apache.hadoop.conf.Configuration	conf
private static final String	CUSTOM_STAGING_DIR
private org.apache.hadoop.hdfs.DistributedFileSystem	dfs
private static byte[]	FAMILY
private static final String	host1
private static final String	host2
private static final String	host3
private HBaseTestingUtil	htu
private String	methodName
private final byte[]	randomBytes
private static final String	STAGING_DIR

Constructor Summary

Constructors

Constructor	Description
TestSecureBulkloadListener()

Method Summary

Modifier and Type	Method	Description
private String	createHFileForFamilies(byte[] family)
private static String	generateUniqueName(String suffix)
void	setUp(org.junit.jupiter.api.TestInfo testInfo)
void	tearDown()
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 Details

conf

private org.apache.hadoop.conf.Configuration conf

htu

private HBaseTestingUtil htu

dfs

private org.apache.hadoop.hdfs.DistributedFileSystem dfs

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

methodName

private String methodName

Constructor Details

TestSecureBulkloadListener

public TestSecureBulkloadListener()

Method Details

setUp

@BeforeEach
public void setUp(org.junit.jupiter.api.TestInfo testInfo)
           throws Exception

Throws:

Exception

tearDown

@AfterEach
public void tearDown()
              throws Exception

Throws:

Exception

testMovingStagedFile

@Test
public void testMovingStagedFile()
                          throws Exception

Throws:

Exception

testMovingStagedFileWithCustomStageDir

@Test
public void testMovingStagedFileWithCustomStageDir()
                                            throws Exception

Throws:

Exception

testCopiedStagedFile

@Test
public void testCopiedStagedFile()
                          throws Exception

Throws:

Exception

testDeletedStagedFile

@Test
public void testDeletedStagedFile()
                           throws Exception

Throws:

Exception

createHFileForFamilies

private String createHFileForFamilies(byte[] family)
                               throws IOException

Throws:

IOException

generateUniqueName

private static String generateUniqueName(String suffix)