org.apache.accumulo.test.functional
Class FunctionalTest
java.lang.Object
org.apache.accumulo.test.functional.FunctionalTest
- Direct Known Subclasses:
- AddSplitTest, BadIteratorMincTest, BatchScanSplitTest, BatchWriterFlushTest, BloomFilterTest, BulkFileTest, BulkSplitOptimizationTest, ConcurrencyTest, ConstraintTest, CreateAndUseTest, CreateManyScannersTest, DeleteEverythingTest, DeleteRowsSplitTest, DeleteRowsTest, FateStarvationTest, LargeRowTest, LogicalTimeTest, MaxOpenTest, MergeTest, PermissionsTest.SystemPermissionsTest, PermissionsTest.TablePermissionsTest, RowDeleteTest, ScanIteratorTest, ScanRangeTest, ScanSessionTimeOutTest, ServerSideErrorTest, SparseColumnFamilyTest, SplitRecoveryTest, TimeoutTest, VisibilityTest
public abstract class FunctionalTest
- extends Object
Method Summary |
protected void |
bulkImport(org.apache.hadoop.fs.FileSystem fs,
String table,
String dir)
|
protected void |
checkRFiles(String tableName,
int minTablets,
int maxTablets,
int minRFiles,
int maxRFiles)
A utility function that checks that each tablet has an expected number of rfiles. |
protected void |
checkSplits(String table,
int min,
int max)
A utility method for use by functional test that ensures a tables has between min and max split points inclusive. |
abstract void |
cleanup()
|
protected Connector |
getConnector()
|
abstract Map<String,String> |
getInitialConfig()
|
protected Instance |
getInstance()
|
protected String |
getPrincipal()
|
abstract List<FunctionalTest.TableSetup> |
getTablesToCreate()
|
protected AuthenticationToken |
getToken()
|
static void |
main(String[] args)
|
static Map<String,String> |
parseConfig(String... perTableConfigs)
|
abstract void |
run()
|
protected void |
setInstanceName(String instanceName)
|
protected void |
setPrincipal(String princ)
|
protected void |
setToken(AuthenticationToken token)
|
void |
setup()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
FunctionalTest
public FunctionalTest()
parseConfig
public static Map<String,String> parseConfig(String... perTableConfigs)
setPrincipal
protected void setPrincipal(String princ)
getPrincipal
protected String getPrincipal()
setToken
protected void setToken(AuthenticationToken token)
getToken
protected AuthenticationToken getToken()
getConnector
protected Connector getConnector()
throws AccumuloException,
AccumuloSecurityException
- Throws:
AccumuloException
AccumuloSecurityException
getInstance
protected Instance getInstance()
setInstanceName
protected void setInstanceName(String instanceName)
getInitialConfig
public abstract Map<String,String> getInitialConfig()
getTablesToCreate
public abstract List<FunctionalTest.TableSetup> getTablesToCreate()
run
public abstract void run()
throws Exception
- Throws:
Exception
cleanup
public abstract void cleanup()
throws Exception
- Throws:
Exception
setup
public void setup()
throws Exception
- Throws:
Exception
checkSplits
protected void checkSplits(String table,
int min,
int max)
throws Exception
- A utility method for use by functional test that ensures a tables has between min and max split points inclusive. If not an exception is thrown.
- Throws:
Exception
checkRFiles
protected void checkRFiles(String tableName,
int minTablets,
int maxTablets,
int minRFiles,
int maxRFiles)
throws Exception
- A utility function that checks that each tablet has an expected number of rfiles.
- Throws:
Exception
bulkImport
protected void bulkImport(org.apache.hadoop.fs.FileSystem fs,
String table,
String dir)
throws Exception
- Throws:
Exception
main
public static void main(String[] args)
throws Exception
- Throws:
Exception
Copyright © 2013 Apache Accumulo Project. All Rights Reserved.