Package org.apache.hadoop.hbase.backup.mapreduce

Class TestBulkLoadCollectorJob

java.lang.Object

org.apache.hadoop.hbase.backup.mapreduce.TestBulkLoadCollectorJob

@Tag("org.apache.hadoop.hbase.testclassification.MapReduceTests") @Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestBulkLoadCollectorJob
extends Object

Unit tests for BulkLoadCollectorJob (mapper, reducer and job creation/validation).

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.conf.Configuration	conf

Constructor Summary

Constructors

Constructor	Description
TestBulkLoadCollectorJob()

Method Summary

Modifier and Type	Method	Description
void	setUp()
void	tearDown()
void	testCreateSubmittableJob_throwsForInsufficientArgs()	Verifies that BulkLoadCollectorJob.createSubmittableJob(String[]) throws an IOException when called with insufficient or null arguments.
void	testCreateSubmittableJob_throwsForNullArgs()
void	testCreateSubmittableJobValid()	Ensures BulkLoadCollectorJob.createSubmittableJob(String[]) correctly configures input/output paths and parses time options into the job configuration.
void	testDedupReducerWritesOnce()	Verifies that BulkLoadCollectorJob.DedupReducer writes each unique key exactly once.
void	testMapperHandlesNullKeyOrValue()	Verifies that BulkLoadCollectorJob.BulkLoadCollectorMapper safely handles null inputs.
void	testMapperIgnoresWhenTableNotInMap()	Verifies that BulkLoadCollectorJob.BulkLoadCollectorMapper ignores WAL entries whose table is not present in the configured tables map.

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

Constructor Details

TestBulkLoadCollectorJob

public TestBulkLoadCollectorJob()

Method Details

setUp

@BeforeEach
public void setUp()

tearDown

@AfterEach
public void tearDown()

testCreateSubmittableJobValid

@Test
public void testCreateSubmittableJobValid()
                                   throws Exception

Ensures BulkLoadCollectorJob.createSubmittableJob(String[]) correctly configures input/output paths and parses time options into the job configuration.

Throws:

Exception

testCreateSubmittableJob_throwsForInsufficientArgs

@Test
public void testCreateSubmittableJob_throwsForInsufficientArgs()
                                                        throws Exception

Verifies that BulkLoadCollectorJob.createSubmittableJob(String[]) throws an IOException when called with insufficient or null arguments.

Throws:

Exception

testCreateSubmittableJob_throwsForNullArgs

@Test
public void testCreateSubmittableJob_throwsForNullArgs()
                                                throws Exception

Throws:

Exception

testMapperIgnoresWhenTableNotInMap

@Test
public void testMapperIgnoresWhenTableNotInMap()
                                        throws Exception

Verifies that BulkLoadCollectorJob.BulkLoadCollectorMapper ignores WAL entries whose table is not present in the configured tables map.

Throws:

Exception

testMapperHandlesNullKeyOrValue

@Test
public void testMapperHandlesNullKeyOrValue()
                                     throws Exception

Verifies that BulkLoadCollectorJob.BulkLoadCollectorMapper safely handles null inputs.

The mapper should ignore WAL entries when either the WAL key or the WALEdit value is null, and must not emit any output in those cases.

Throws:

Exception - on test failure

testDedupReducerWritesOnce

@Test
public void testDedupReducerWritesOnce()
                                throws Exception

Verifies that BulkLoadCollectorJob.DedupReducer writes each unique key exactly once.

Throws:

Exception