Package org.apache.hadoop.hbase.mapreduce

Class TestImportTSVWithOperationAttributes

java.lang.Object

org.apache.hadoop.hbase.mapreduce.TestImportTSVWithOperationAttributes

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable

@Tag("org.apache.hadoop.hbase.testclassification.MapReduceTests") @Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestImportTSVWithOperationAttributes
extends Object
implements org.apache.hadoop.conf.Configurable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestImportTSVWithOperationAttributes.OperationAttributesTestController

Field Summary

Fields

Modifier and Type	Field	Description
private static org.apache.hadoop.conf.Configuration	conf
protected static final String	DELETE_AFTER_LOAD_CONF	Delete the tmp directory after running doMROnTableTest.
private final String	FAMILY
protected static final String	FORCE_COMBINER_CONF	Force use of combiner in doMROnTableTest.
private static final org.slf4j.Logger	LOG
protected static final String	NAME
private static final String	TEST_ATR_KEY
protected static HBaseTestingUtil	util

Constructor Summary

Constructors

Constructor	Description
TestImportTSVWithOperationAttributes()

Method Summary

Modifier and Type	Method	Description
private org.apache.hadoop.util.Tool	doMROnTableTest(HBaseTestingUtil util, String family, String data, String[] args, int valueMultiplier, boolean dataAvailable)	Run an ImportTsv job and perform basic validation on the results.
org.apache.hadoop.conf.Configuration	getConf()
static void	provisionCluster()
static void	releaseCluster()
void	setConf(org.apache.hadoop.conf.Configuration conf)
void	testMROnTable(org.junit.jupiter.api.TestInfo testInfo)
void	testMROnTableWithInvalidOperationAttr(org.junit.jupiter.api.TestInfo testInfo)
private static void	validateTable(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.TableName tableName, String family, int valueMultiplier, boolean dataAvailable)	Confirm ImportTsv via data in online table.

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

NAME

protected static final String NAME

util

protected static HBaseTestingUtil util

DELETE_AFTER_LOAD_CONF

protected static final String DELETE_AFTER_LOAD_CONF

Delete the tmp directory after running doMROnTableTest. Boolean. Default is false.

FORCE_COMBINER_CONF

protected static final String FORCE_COMBINER_CONF

Force use of combiner in doMROnTableTest. Boolean. Default is true.

conf

private static org.apache.hadoop.conf.Configuration conf

TEST_ATR_KEY

private static final String TEST_ATR_KEY

See Also:

• Constant Field Values

FAMILY

private final String FAMILY

See Also:

• Constant Field Values

Constructor Details

TestImportTSVWithOperationAttributes

public TestImportTSVWithOperationAttributes()

Method Details

getConf

public org.apache.hadoop.conf.Configuration getConf()

Specified by:

getConf in interface org.apache.hadoop.conf.Configurable

setConf

public void setConf(org.apache.hadoop.conf.Configuration conf)

Specified by:

setConf in interface org.apache.hadoop.conf.Configurable

provisionCluster

@BeforeAll
public static void provisionCluster()
                             throws Exception

Throws:

Exception

releaseCluster

@AfterAll
public static void releaseCluster()
                           throws Exception

Throws:

Exception

testMROnTable

@Test
public void testMROnTable(org.junit.jupiter.api.TestInfo testInfo)
                   throws Exception

Throws:

Exception

testMROnTableWithInvalidOperationAttr

@Test
public void testMROnTableWithInvalidOperationAttr(org.junit.jupiter.api.TestInfo testInfo)
                                           throws Exception

Throws:

Exception

doMROnTableTest

private org.apache.hadoop.util.Tool doMROnTableTest(HBaseTestingUtil util,
 String family,
 String data,
 String[] args,
 int valueMultiplier,
 boolean dataAvailable)
                                             throws Exception

Run an ImportTsv job and perform basic validation on the results. Returns the ImportTsv Tool instance so that other tests can inspect it for further validation as necessary. This method is static to insure non-reliance on instance's util/conf facilities. Any arguments to pass BEFORE inputFile path is appended.

Returns:

The Tool instance used to run the test.

Throws:

Exception

validateTable

private static void validateTable(org.apache.hadoop.conf.Configuration conf,
 org.apache.hadoop.hbase.TableName tableName,
 String family,
 int valueMultiplier,
 boolean dataAvailable)
                           throws IOException

Confirm ImportTsv via data in online table.

Throws:

IOException