Package org.apache.hadoop.hbase.client

Class ClientPushbackTestBase

java.lang.Object

org.apache.hadoop.hbase.client.ClientPushbackTestBase

Direct Known Subclasses:

TestAsyncClientPushback, TestClientPushback

public abstract class ClientPushbackTestBase
extends Object

Test that we can actually send and use region metrics to slowdown client writes

Field Summary

Fields

Modifier and Type	Field	Description
private static final byte[]	family
private static final long	flushSizeBytes
private static final org.slf4j.Logger	LOG
private static final byte[]	qualifier
protected static final org.apache.hadoop.hbase.TableName	tableName
protected static final HBaseTestingUtility	UTIL

Constructor Summary

Constructors

Constructor	Description
ClientPushbackTestBase()

Method Summary

Modifier and Type	Method	Description
static void	cleanupCluster()
protected abstract org.apache.hadoop.hbase.client.backoff.ClientBackoffPolicy	getBackoffPolicy()
protected abstract org.apache.hadoop.hbase.client.MetricsConnection	getConnectionMetrics()
protected abstract org.apache.hadoop.hbase.client.ServerStatisticTracker	getStatisticsTracker()
protected abstract void	mutate(org.apache.hadoop.hbase.client.Put put)
protected abstract void	mutate(org.apache.hadoop.hbase.client.Put put, AtomicLong endTime, CountDownLatch latch)
protected abstract void	mutateRow(org.apache.hadoop.hbase.client.RowMutations mutations)
static void	setupCluster()
void	testClientTracksServerPushback()
void	testMutateRowStats()

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

UTIL

protected static final HBaseTestingUtility UTIL

tableName

protected static final org.apache.hadoop.hbase.TableName tableName

family

private static final byte[] family

qualifier

private static final byte[] qualifier

flushSizeBytes

private static final long flushSizeBytes

See Also:

• Constant Field Values

Constructor Details

ClientPushbackTestBase

public ClientPushbackTestBase()

Method Details

setupCluster

public static void setupCluster()
                         throws Exception

Throws:

Exception

cleanupCluster

public static void cleanupCluster()
                           throws Exception

Throws:

Exception

getBackoffPolicy

protected abstract org.apache.hadoop.hbase.client.backoff.ClientBackoffPolicy getBackoffPolicy()
                                                                                        throws IOException

Throws:

IOException

getStatisticsTracker

protected abstract org.apache.hadoop.hbase.client.ServerStatisticTracker getStatisticsTracker()
                                                                                       throws IOException

Throws:

IOException

getConnectionMetrics

protected abstract org.apache.hadoop.hbase.client.MetricsConnection getConnectionMetrics()
                                                                                  throws IOException

Throws:

IOException

mutate

protected abstract void mutate(org.apache.hadoop.hbase.client.Put put)
                        throws IOException

Throws:

IOException

mutate

protected abstract void mutate(org.apache.hadoop.hbase.client.Put put,
 AtomicLong endTime,
 CountDownLatch latch)
                        throws IOException

Throws:

IOException

mutateRow

protected abstract void mutateRow(org.apache.hadoop.hbase.client.RowMutations mutations)
                           throws IOException

Throws:

IOException

testClientTracksServerPushback

public void testClientTracksServerPushback()
                                    throws Exception

Throws:

Exception

testMutateRowStats

public void testMutateRowStats()
                        throws IOException

Throws:

IOException