Package org.apache.hadoop.hbase.client

Class FromClientSideTest2

java.lang.Object

org.apache.hadoop.hbase.client.FromClientSideTestBase

org.apache.hadoop.hbase.client.FromClientSideTest2

Direct Known Subclasses:

TestFromClientSide2, TestFromClientSide2WithCoprocessor, TestFromClientSide2WoUnsafe

public class FromClientSideTest2
extends FromClientSideTestBase

Field Summary

Fields

Modifier and Type	Field	Description
private static byte[]	ANOTHERROW
private static byte[]	COL_QUAL
private static final org.slf4j.Logger	LOG
private static byte[]	ROW_BYTES
private static byte[]	VAL_BYTES
private static int	WAITTABLE_MILLIS

Fields inherited from class org.apache.hadoop.hbase.client.FromClientSideTestBase

FAMILY, INVALID_FAMILY, numHedgedReqs, QUALIFIER, registryImpl, ROW, SLAVES, tableName, TEST_UTIL, VALUE

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	FromClientSideTest2(Class<? extends org.apache.hadoop.hbase.client.ConnectionRegistry> registryImpl, int numHedgedReqs)

Method Summary

Modifier and Type	Method	Description
private int	getStoreFileCount(org.apache.hadoop.hbase.client.Admin admin, org.apache.hadoop.hbase.ServerName serverName, org.apache.hadoop.hbase.client.RegionInfo region)
private void	performMultiplePutAndFlush(org.apache.hadoop.hbase.client.Admin admin, org.apache.hadoop.hbase.client.Table table, byte[] row, byte[] family, int nFlushes, int nPuts)
private void	randomCFPuts(org.apache.hadoop.hbase.client.Table table, byte[] row, byte[] family, int nPuts)
protected static void	startCluster(Class<?>... cps)
void	testAdvancedConfigOverride()
void	testBatchWithCheckAndMutate()
void	testBatchWithRowMutation()
void	testConnectionDefaultUsesCodec()
void	testGetEmptyRow()
void	testHTableBatchWithEmptyPut()
void	testHTableExistsAllBeforeGet()
void	testHTableExistsBeforeGet()
void	testHTableExistsMethodSingleRegionMultipleGets()
void	testHTableExistsMethodSingleRegionSingleGet()
void	testHTableWithLargeBatch()

Methods inherited from class org.apache.hadoop.hbase.client.FromClientSideTestBase

assertDoubleResult, assertEmptyResult, assertIncrementKey, assertKey, assertNResult, assertNResult, assertNullResult, assertNumKeys, assertRowCount, assertSingleResult, assertSingleResult, assertSingleResult, buildScanner, createScanWithRowFilter, createScanWithRowFilter, deleteColumns, equals, getAllVersionsAndVerify, getClientConf, getConnection, getNumberOfRows, getSingleScanResult, getTestNull, getTestNull, getVerifySingleColumn, getVerifySingleEmpty, getVersionAndVerify, getVersionAndVerifyMissing, getVersionRangeAndVerify, getVersionRangeAndVerifyGreaterThan, initialize, makeN, makeNAscii, makeNBig, makeStamps, parameters, putRows, scanAllVersionsAndVerify, scanTestNull, scanTestNull, scanVerifySingleColumn, scanVerifySingleEmpty, scanVersionAndVerify, scanVersionAndVerifyMissing, scanVersionRangeAndVerify, scanVersionRangeAndVerifyGreaterThan, setUp, singleRowGetTest, singleRowScanTest, splitTable, tearDown, tearDownAfterClass

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

WAITTABLE_MILLIS

private static int WAITTABLE_MILLIS

ANOTHERROW

private static byte[] ANOTHERROW

COL_QUAL

private static byte[] COL_QUAL

VAL_BYTES

private static byte[] VAL_BYTES

ROW_BYTES

private static byte[] ROW_BYTES

Constructor Details

FromClientSideTest2

protected FromClientSideTest2(Class<? extends org.apache.hadoop.hbase.client.ConnectionRegistry> registryImpl,
 int numHedgedReqs)

Method Details

startCluster

protected static void startCluster(Class<?>... cps)
                            throws Exception

Throws:

Exception

testHTableBatchWithEmptyPut

@TestTemplate
public void testHTableBatchWithEmptyPut()
                                 throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testHTableWithLargeBatch

@TestTemplate
public void testHTableWithLargeBatch()
                              throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testBatchWithRowMutation

@TestTemplate
public void testBatchWithRowMutation()
                              throws Exception

Throws:

Exception

testBatchWithCheckAndMutate

@TestTemplate
public void testBatchWithCheckAndMutate()
                                 throws Exception

Throws:

Exception

testHTableExistsMethodSingleRegionSingleGet

@TestTemplate
public void testHTableExistsMethodSingleRegionSingleGet()
                                                 throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testHTableExistsMethodSingleRegionMultipleGets

@TestTemplate
public void testHTableExistsMethodSingleRegionMultipleGets()
                                                    throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testHTableExistsBeforeGet

@TestTemplate
public void testHTableExistsBeforeGet()
                               throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testHTableExistsAllBeforeGet

@TestTemplate
public void testHTableExistsAllBeforeGet()
                                  throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testGetEmptyRow

@TestTemplate
public void testGetEmptyRow()
                     throws Exception

Throws:

Exception

testConnectionDefaultUsesCodec

@TestTemplate
public void testConnectionDefaultUsesCodec()
                                    throws Exception

Throws:

Exception

randomCFPuts

private void randomCFPuts(org.apache.hadoop.hbase.client.Table table,
 byte[] row,
 byte[] family,
 int nPuts)
                   throws Exception

Throws:

Exception

performMultiplePutAndFlush

private void performMultiplePutAndFlush(org.apache.hadoop.hbase.client.Admin admin,
 org.apache.hadoop.hbase.client.Table table,
 byte[] row,
 byte[] family,
 int nFlushes,
 int nPuts)
                                 throws Exception

Throws:

Exception

getStoreFileCount

private int getStoreFileCount(org.apache.hadoop.hbase.client.Admin admin,
 org.apache.hadoop.hbase.ServerName serverName,
 org.apache.hadoop.hbase.client.RegionInfo region)
                       throws IOException

Throws:

IOException

testAdvancedConfigOverride

@TestTemplate
public void testAdvancedConfigOverride()
                                throws Exception

Throws:

Exception