public class IntegrationTestImportTsv
extends Configured
Modifier and Type | Field and Description |
---|---|
TestName |
name |
protected static java.util.Set<KeyValue> |
simple_expected |
protected static java.lang.String |
simple_tsv |
protected static IntegrationTestingUtility |
util |
Constructor and Description |
---|
IntegrationTestImportTsv() |
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(java.lang.String[] args) |
static void |
provisionCluster() |
static void |
releaseCluster() |
int |
run(java.lang.String[] args) |
void |
setConf(Configuration conf) |
void |
testGenerateAndLoad() |
protected static void |
validateDeletedPartitionsFile(Configuration conf)
Confirm the absence of the
TotalOrderPartitioner partitions file. |
protected static final java.lang.String simple_tsv
public TestName name
protected static final java.util.Set<KeyValue> simple_expected
protected static IntegrationTestingUtility util
public Configuration getConf()
public void setConf(Configuration conf)
public static void provisionCluster() throws java.lang.Exception
java.lang.Exception
public static void releaseCluster() throws java.lang.Exception
java.lang.Exception
protected void doLoadIncrementalHFiles(Path hfiles, TableName tableName) throws java.lang.Exception
simple_tsv
matches
simple_expected
.java.lang.Exception
protected static void validateDeletedPartitionsFile(Configuration conf) throws java.io.IOException
TotalOrderPartitioner
partitions file.java.io.IOException
public void testGenerateAndLoad() throws java.lang.Exception
java.lang.Exception
public int run(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception
public static void main(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception