org.apache.accumulo.test.functional
Class FunctionalTest

java.lang.Object
  extended by 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


Nested Class Summary
static class FunctionalTest.TableSetup
           
 
Constructor Summary
FunctionalTest()
           
 
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
 

Constructor Detail

FunctionalTest

public FunctionalTest()
Method Detail

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.