Logo Search packages:      
Sourcecode: hbase version File versions  Download package

org::apache::hadoop::hbase::client::TestClient Class Reference

Inheritance diagram for org::apache::hadoop::hbase::client::TestClient:

org::apache::hadoop::hbase::HBaseClusterTestCase org::apache::hadoop::hbase::HBaseTestCase

List of all members.


Detailed Description

Tests from client-side of a cluster.

Definition at line 54 of file TestClient.java.


Public Member Functions

 TestClient ()
void testDeletes () throws Exception
void testFilterAcrossMutlipleRegions () throws IOException
void testFilters () throws Exception
void testJIRAs () throws Exception
void testNull () throws Exception
void testSimpleMissing () throws Exception
void testSingleRowMultipleFamily () throws Exception
void testSuperSimple () throws Exception
void testVersionLimits () throws Exception
void testVersions () throws Exception
void testWeirdCacheBehaviour () throws Exception
void threadDumpingJoin ()
void XtestDuplicateVersions () throws Exception
void XtestMillions () throws Exception
void XtestMultipleRegionsAndBatchPuts () throws Exception
void XtestMultipleRowMultipleFamily () throws Exception

Public Attributes

MiniHBaseCluster cluster
volatile HBaseConfiguration conf

Static Public Attributes

static final String TEST_DIRECTORY_KEY = "test.build.data"

Protected Member Functions

HRegion createNewHRegion (HTableDescriptor desc, byte[] startKey, byte[] endKey) throws IOException
HTableDescriptor createTableDescriptor (final String name, final int versions)
HTableDescriptor createTableDescriptor (final String name)
Path getUnitTestdir (String testName)
void hBaseClusterSetup () throws Exception
HRegion openClosedRegion (final HRegion closedRegion) throws IOException
void postHBaseClusterSetup () throws Exception
void preHBaseClusterSetup () throws Exception
void setOpenMetaTable (boolean val)
void setUp () throws Exception
void tearDown () throws Exception
void threadDumpingJoin (final Thread t)

Static Protected Member Functions

static long addContent (final Incommon updater, final String columnFamily, final String column, final byte[] startKeyBytes, final byte[] endKey, final long ts) throws IOException
static long addContent (final Incommon updater, final String family, final String column, final byte[] startKeyBytes, final byte[] endKey) throws IOException
static long addContent (final Incommon updater, final String columnFamily, final byte[] startKeyBytes, final byte[] endKey) throws IOException
static long addContent (final Incommon updater, final String family, final String column) throws IOException
static long addContent (final Incommon updater, final String columnFamily) throws IOException
static long addContent (final HRegion r, final byte[] columnFamily) throws IOException

Protected Attributes

MiniDFSCluster dfsCluster
FileSystem fs = null
HRegion meta = null
int regionServers
HRegion root = null
String START_KEY
boolean startDfs
Path testDir = null
MiniZooKeeperCluster zooKeeperCluster

Static Protected Attributes

static final byte[][] COLUMNS = {fam1, fam2, fam3}
static final byte[] fam1 = Bytes.toBytes("colfamily1")
static final byte[] fam2 = Bytes.toBytes("colfamily2")
static final byte[] fam3 = Bytes.toBytes("colfamily3")
static final char FIRST_CHAR = 'a'
static final char LAST_CHAR = 'z'
static final int MAXVERSIONS = 3
static final String PUNCTUATION = "~`@#$%^&*()-_+=:;',.<>/?[]{}|"
static final byte[] START_KEY_BYTES = {FIRST_CHAR, FIRST_CHAR, FIRST_CHAR}

Static Package Functions

 [static initializer]

Package Attributes

final Log LOG = LogFactory.getLog(getClass())

Private Member Functions

void assertDoubleResult (Result result, byte[] row, byte[] familyA, byte[] qualifierA, byte[] valueA, byte[] familyB, byte[] qualifierB, byte[] valueB) throws Exception
void assertEmptyResult (Result result) throws Exception
void assertKey (KeyValue key, byte[] row, byte[] family, byte[] qualifier, byte[] value) throws Exception
void assertNResult (Result result, byte[] row, byte[] family, byte[] qualifier, long[] stamps, byte[][] values, int start, int end) throws IOException
void assertNResult (Result result, byte[] row, byte[][] families, byte[][] qualifiers, byte[][] values, int[][] idxs) throws Exception
void assertNullResult (Result result) throws Exception
void assertNumKeys (Result result, int n) throws Exception
void assertRowCount (final HTable t, final int expected) throws IOException
void assertSingleResult (Result result, byte[] row, byte[] family, byte[] qualifier, long ts, byte[] value) throws Exception
void assertSingleResult (Result result, byte[] row, byte[] family, byte[] qualifier, byte[] value) throws Exception
ResultScanner buildScanner (String keyPrefix, String value, HTable ht) throws IOException
int countRows (final HTable t, final Scan s) throws IOException
Scan createScanWithRowFilter (final byte[] key, final byte[] startRow, CompareFilter.CompareOp op)
Scan createScanWithRowFilter (final byte[] key)
HTable createTable (byte[] tableName, byte[][] families, int[] numVersions) throws IOException
HTable createTable (byte[] tableName, byte[][] families, int numVersions) throws IOException
HTable createTable (byte[] tableName, byte[] family, int numVersions) throws IOException
HTable createTable (byte[] tableName, byte[][] families) throws IOException
HTable createTable (byte[] tableName, byte[] family) throws IOException
void deleteColumns (HTable ht, String value, String keyPrefix) throws IOException
boolean equals (byte[] left, byte[] right)
void flushMemStore (byte[] tableName) throws Exception
void getAllVersionsAndVerify (HTable ht, byte[] row, byte[] family, byte[] qualifier, long[] stamps, byte[][] values, int start, int end) throws IOException
int getNumberOfRows (String keyPrefix, String value, HTable ht) throws Exception
Result getSingleScanResult (HTable ht, Scan scan) throws IOException
void getTestNull (HTable ht, byte[] row, byte[] family, byte[] value) throws Exception
void getVerifySingleColumn (HTable ht, byte[][] ROWS, int ROWIDX, byte[][] FAMILIES, int FAMILYIDX, byte[][] QUALIFIERS, int QUALIFIERIDX, byte[][] VALUES, int VALUEIDX) throws Exception
void getVerifySingleEmpty (HTable ht, byte[][] ROWS, int ROWIDX, byte[][] FAMILIES, int FAMILYIDX, byte[][] QUALIFIERS, int QUALIFIERIDX) throws Exception
void getVersionAndVerify (HTable ht, byte[] row, byte[] family, byte[] qualifier, long stamp, byte[] value) throws Exception
void getVersionAndVerifyMissing (HTable ht, byte[] row, byte[] family, byte[] qualifier, long stamp) throws Exception
void getVersionRangeAndVerify (HTable ht, byte[] row, byte[] family, byte[] qualifier, long[] stamps, byte[][] values, int start, int end) throws IOException
void getVersionRangeAndVerifyGreaterThan (HTable ht, byte[] row, byte[] family, byte[] qualifier, long[] stamps, byte[][] values, int start, int end) throws IOException
void jiraTest1014 () throws Exception
void jiraTest1182 () throws Exception
void jiraTest33 () throws Exception
void jiraTest52 () throws Exception
void jiraTest861 () throws Exception
void jiraTest867 () throws Exception
int loadTable (final HTable t) throws IOException
byte[][] makeN (byte[] base, int n)
byte[][] makeNAscii (byte[] base, int n)
byte[][] makeNBig (byte[] base, int n)
long[] makeStamps (int n)
void putRows (HTable ht, int numRows, String value, String key) throws IOException
void scanAllVersionsAndVerify (HTable ht, byte[] row, byte[] family, byte[] qualifier, long[] stamps, byte[][] values, int start, int end) throws IOException
void scanTestNull (HTable ht, byte[] row, byte[] family, byte[] value) throws Exception
void scanVerifySingleColumn (HTable ht, byte[][] ROWS, int ROWIDX, byte[][] FAMILIES, int FAMILYIDX, byte[][] QUALIFIERS, int QUALIFIERIDX, byte[][] VALUES, int VALUEIDX) throws Exception
void scanVerifySingleEmpty (HTable ht, byte[][] ROWS, int ROWIDX, byte[][] FAMILIES, int FAMILYIDX, byte[][] QUALIFIERS, int QUALIFIERIDX) throws Exception
void scanVersionAndVerify (HTable ht, byte[] row, byte[] family, byte[] qualifier, long stamp, byte[] value) throws Exception
void scanVersionAndVerifyMissing (HTable ht, byte[] row, byte[] family, byte[] qualifier, long stamp) throws Exception
void scanVersionRangeAndVerify (HTable ht, byte[] row, byte[] family, byte[] qualifier, long[] stamps, byte[][] values, int start, int end) throws IOException
void scanVersionRangeAndVerifyGreaterThan (HTable ht, byte[] row, byte[] family, byte[] qualifier, long[] stamps, byte[][] values, int start, int end) throws IOException
void singleRowGetTest (HTable ht, byte[][] ROWS, byte[][] FAMILIES, byte[][] QUALIFIERS, byte[][] VALUES) throws Exception
void singleRowScanTest (HTable ht, byte[][] ROWS, byte[][] FAMILIES, byte[][] QUALIFIERS, byte[][] VALUES) throws Exception
Map< HRegionInfo, HServerAddresssplitTable (final HTable t) throws IOException
Map< HRegionInfo, HServerAddresswaitOnSplit (final HTable t) throws IOException

Static Private Attributes

static byte[] EMPTY = new byte[0]
static byte[] FAMILY = Bytes.toBytes("testFamily")
static byte[] QUALIFIER = Bytes.toBytes("testQualifier")
static byte[] ROW = Bytes.toBytes("testRow")
static byte[] VALUE = Bytes.toBytes("testValue")

The documentation for this class was generated from the following file:

Generated by  Doxygen 1.6.0   Back to index