public class TestImportTsv extends Object
Modifier and Type | Field and Description |
---|---|
protected static String |
DELETE_AFTER_LOAD_CONF
Delete the tmp directory after running doMROnTableTest.
|
protected static String |
FORCE_COMBINER_CONF
Force use of combiner in doMROnTableTest.
|
protected static Log |
LOG |
protected static String |
NAME |
protected static HBaseTestingUtility |
util |
Constructor and Description |
---|
TestImportTsv() |
Modifier and Type | Method and Description |
---|---|
protected static Tool |
doMROnTableTest(HBaseTestingUtility util,
String family,
String data,
String[] args) |
protected static Tool |
doMROnTableTest(HBaseTestingUtility util,
String family,
String data,
String[] args,
int valueMultiplier)
Run an ImportTsv job and perform basic validation on the results.
|
Configuration |
getConf() |
static void |
provisionCluster() |
static void |
releaseCluster() |
void |
setConf(Configuration conf) |
void |
testBulkOutputWithAnExistingTable() |
void |
testBulkOutputWithAnExistingTableNoStrictTrue() |
void |
testBulkOutputWithoutAnExistingTable() |
void |
testBulkOutputWithTsvImporterTextMapper() |
void |
testJobConfigurationsWithTsvImporterTextMapper() |
void |
testMROnTable() |
void |
testMROnTableWithCustomMapper() |
void |
testMROnTableWithTimestamp() |
void |
testMRWithoutAnExistingTable() |
void |
testWithoutAnExistingTableAndCreateTableSetToNo() |
protected static final Log LOG
protected static final String NAME
protected static HBaseTestingUtility util
protected static final String DELETE_AFTER_LOAD_CONF
protected static final String FORCE_COMBINER_CONF
public Configuration getConf()
public void setConf(Configuration conf)
public void testMROnTableWithTimestamp() throws Exception
Exception
public void testMROnTableWithCustomMapper() throws Exception
Exception
public void testBulkOutputWithoutAnExistingTable() throws Exception
Exception
public void testBulkOutputWithAnExistingTable() throws Exception
Exception
public void testBulkOutputWithAnExistingTableNoStrictTrue() throws Exception
Exception
public void testJobConfigurationsWithTsvImporterTextMapper() throws Exception
Exception
public void testBulkOutputWithTsvImporterTextMapper() throws Exception
Exception
public void testWithoutAnExistingTableAndCreateTableSetToNo() throws Exception
Exception
public void testMRWithoutAnExistingTable() throws Exception
Exception
protected static Tool doMROnTableTest(HBaseTestingUtility util, String family, String data, String[] args) throws Exception
Exception
protected static Tool doMROnTableTest(HBaseTestingUtility util, String family, String data, String[] args, int valueMultiplier) throws Exception
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.args
- Any arguments to pass BEFORE inputFile path is appended.Exception