org.apache.hadoop.hbase.mapreduce

Class IntegrationTestImportTsv

java.lang.Object

org.apache.hadoop.hbase.mapreduce.IntegrationTestImportTsv

public class IntegrationTestImportTsv
extends Object

Validate ImportTsv + LoadIncrementalHFiles on a distributed cluster.

Field Summary

Fields

Modifier and Type	Field and Description
protected static Log	LOG
protected static Set<KeyValue>	simple_expected
protected static String	simple_tsv
protected static IntegrationTestingUtility	util

Constructor Summary

Constructors

Constructor and Description
IntegrationTestImportTsv()

Method Summary

Modifier and Type	Method and Description
protected void	doLoadIncrementalHFiles(Path hfiles, TableName tableName) Verify the data described by simple_tsv matches simple_expected.
Configuration	getConf()
static void	main(String[] args)
static void	provisionCluster()
static void	releaseCluster()
int	run(String[] args)
void	setConf(Configuration conf)
void	testGenerateAndLoad()
protected static void	validateDeletedPartitionsFile(Configuration conf) Confirm the absence of the TotalOrderPartitioner partitions file.

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final Log LOG

simple_tsv

protected static final String simple_tsv

See Also:

Constant Field Values

simple_expected

protected static final Set<KeyValue> simple_expected

util

protected static IntegrationTestingUtility util

Constructor Detail

IntegrationTestImportTsv

public IntegrationTestImportTsv()

Method Detail

getConf

public Configuration getConf()

setConf

public void setConf(Configuration conf)

provisionCluster

public static void provisionCluster()
                             throws Exception

Throws:

Exception

releaseCluster

public static void releaseCluster()
                           throws Exception

Throws:

Exception

doLoadIncrementalHFiles

protected void doLoadIncrementalHFiles(Path hfiles,
                                       TableName tableName)
                                throws Exception

Verify the data described by simple_tsv matches simple_expected.

Throws:

Exception

validateDeletedPartitionsFile

protected static void validateDeletedPartitionsFile(Configuration conf)
                                             throws IOException

Confirm the absence of the TotalOrderPartitioner partitions file.

Throws:

IOException

testGenerateAndLoad

public void testGenerateAndLoad()
                         throws Exception

Throws:

Exception

run

public int run(String[] args)
        throws Exception

Throws:

Exception

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception