Package org.apache.hadoop.hbase.backup.util

Class TestBulkLoadProcessor

java.lang.Object

org.apache.hadoop.hbase.backup.util.TestBulkLoadProcessor

@Tag("org.apache.hadoop.hbase.testclassification.SmallTests")
public class TestBulkLoadProcessor
extends Object

Unit tests for BulkLoadProcessor.

These tests validate the extraction of bulk-loaded file paths from WAL entries under different scenarios, including:

• Valid replicable bulk load entries
• Non-replicable bulk load entries
• Entries with no bulk load qualifier
• Entries containing multiple column families

Constructor Summary

Constructors

Constructor	Description
TestBulkLoadProcessor()

Method Summary

Modifier and Type	Method	Description
private org.apache.hadoop.hbase.wal.WAL.Entry	createBulkLoadWalEntry(org.apache.hadoop.hbase.TableName tableName, String regionName, boolean replicate, String family, String... storeFiles)	Creates a WAL.Entry containing a WALProtos.BulkLoadDescriptor with the given parameters.
void	testProcessBulkLoadFiles_listApi_delegatesToSingle()	Sanity check: list-based API should still work and return the same results as invoking the single-entry API for the same entry (ensures delegation/backwards compatibility).
void	testProcessBulkLoadFiles_multipleFamilies()	Verifies that multiple WAL entries with different column families produce the correct set of file paths.
void	testProcessBulkLoadFiles_multipleFamilies_singleEntryApi()
void	testProcessBulkLoadFiles_noBulkLoadQualifier()	Verifies that entries without the BULK_LOAD qualifier are ignored.
void	testProcessBulkLoadFiles_noBulkLoadQualifier_singleEntryApi()
void	testProcessBulkLoadFiles_nonReplicableSkipped()	Verifies that a non-replicable bulk load entry is ignored.
void	testProcessBulkLoadFiles_nonReplicableSkipped_singleEntryApi()
void	testProcessBulkLoadFiles_validEntry()	Verifies that a valid replicable bulk load WAL entry produces the correct number and structure of file paths.
void	testProcessBulkLoadFiles_validEntry_singleEntryApi()

Methods inherited from class java.lang.Object

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

Constructor Details

TestBulkLoadProcessor

public TestBulkLoadProcessor()

Method Details

createBulkLoadWalEntry

private org.apache.hadoop.hbase.wal.WAL.Entry createBulkLoadWalEntry(org.apache.hadoop.hbase.TableName tableName,
 String regionName,
 boolean replicate,
 String family,
 String... storeFiles)

Creates a WAL.Entry containing a WALProtos.BulkLoadDescriptor with the given parameters.

Parameters:

tableName - The table name

regionName - The encoded region name

replicate - Whether the bulk load is marked for replication

family - Column family name

storeFiles - One or more store file names to include

Returns:

A WAL.Entry representing the bulk load event

testProcessBulkLoadFiles_validEntry

@Test
public void testProcessBulkLoadFiles_validEntry()
                                         throws IOException

Verifies that a valid replicable bulk load WAL entry produces the correct number and structure of file paths.

Throws:

IOException

testProcessBulkLoadFiles_validEntry_singleEntryApi

@Test
public void testProcessBulkLoadFiles_validEntry_singleEntryApi()
                                                        throws IOException

Throws:

IOException

testProcessBulkLoadFiles_nonReplicableSkipped

@Test
public void testProcessBulkLoadFiles_nonReplicableSkipped()
                                                   throws IOException

Verifies that a non-replicable bulk load entry is ignored.

Throws:

IOException

testProcessBulkLoadFiles_nonReplicableSkipped_singleEntryApi

@Test
public void testProcessBulkLoadFiles_nonReplicableSkipped_singleEntryApi()
                                                                  throws IOException

Throws:

IOException

testProcessBulkLoadFiles_noBulkLoadQualifier

@Test
public void testProcessBulkLoadFiles_noBulkLoadQualifier()
                                                  throws IOException

Verifies that entries without the BULK_LOAD qualifier are ignored.

Throws:

IOException

testProcessBulkLoadFiles_noBulkLoadQualifier_singleEntryApi

@Test
public void testProcessBulkLoadFiles_noBulkLoadQualifier_singleEntryApi()
                                                                 throws IOException

Throws:

IOException

testProcessBulkLoadFiles_multipleFamilies

@Test
public void testProcessBulkLoadFiles_multipleFamilies()
                                               throws IOException

Verifies that multiple WAL entries with different column families produce the correct set of file paths.

Throws:

IOException

testProcessBulkLoadFiles_multipleFamilies_singleEntryApi

@Test
public void testProcessBulkLoadFiles_multipleFamilies_singleEntryApi()
                                                              throws IOException

Throws:

IOException

testProcessBulkLoadFiles_listApi_delegatesToSingle

@Test
public void testProcessBulkLoadFiles_listApi_delegatesToSingle()
                                                        throws IOException

Sanity check: list-based API should still work and return the same results as invoking the single-entry API for the same entry (ensures delegation/backwards compatibility).

Throws:

IOException