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 and Description
private static byte[]	family
private static long	flushSizeBytes
private static org.slf4j.Logger	LOG
private static byte[]	qualifier
protected static org.apache.hadoop.hbase.TableName	tableName
protected static HBaseTestingUtility	UTIL

Constructor Summary

Constructors

Constructor and Description
ClientPushbackTestBase()

Method Summary

Modifier and Type	Method and 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 Detail

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 Detail

ClientPushbackTestBase

public ClientPushbackTestBase()

Method Detail

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