org.apache.hadoop.hbase.regionserver.throttle

Class TestFlushWithThroughputController

java.lang.Object

org.apache.hadoop.hbase.regionserver.throttle.TestFlushWithThroughputController

public class TestFlushWithThroughputController
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static double	EPSILON
private byte[]	family
private HBaseTestingUtility	hbtu
private static org.slf4j.Logger	LOG
private byte[]	qualifier
private org.apache.hadoop.hbase.TableName	tableName
org.junit.rules.TestName	testName

Constructor Summary

Constructors

Constructor and Description
TestFlushWithThroughputController()

Method Summary

Modifier and Type	Method and Description
private org.apache.hadoop.hbase.util.Pair<Double,Long>	generateAndFlushData(org.apache.hadoop.hbase.client.Table table) Writes Puts to the table and flushes few times.
private org.apache.hadoop.hbase.regionserver.HStore	getStoreWithName(org.apache.hadoop.hbase.TableName tableName)
private void	setMaxMinThroughputs(long max, long min)
void	setUp()
void	tearDown()
void	testFlushControl()
void	testFlushControlForStripedStore() Test the logic for striped store.
void	testFlushThroughputTuning() Test the tuning task of PressureAwareFlushThroughputController
private long	testFlushWithThroughputLimit()

Methods inherited from class java.lang.Object

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

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

EPSILON

private static final double EPSILON

See Also:

Constant Field Values

hbtu

private HBaseTestingUtility hbtu

testName

public org.junit.rules.TestName testName

tableName

private org.apache.hadoop.hbase.TableName tableName

family

private final byte[] family

qualifier

private final byte[] qualifier

Constructor Detail

TestFlushWithThroughputController

public TestFlushWithThroughputController()

Method Detail

setUp

public void setUp()

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

getStoreWithName

private org.apache.hadoop.hbase.regionserver.HStore getStoreWithName(org.apache.hadoop.hbase.TableName tableName)

setMaxMinThroughputs

private void setMaxMinThroughputs(long max,
                                  long min)

generateAndFlushData

private org.apache.hadoop.hbase.util.Pair<Double,Long> generateAndFlushData(org.apache.hadoop.hbase.client.Table table)
                                                                     throws IOException

Writes Puts to the table and flushes few times.

Returns:

Pair of (throughput, duration).

Throws:

IOException

testFlushWithThroughputLimit

private long testFlushWithThroughputLimit()
                                   throws Exception

Throws:

Exception

testFlushControl

public void testFlushControl()
                      throws Exception

Throws:

Exception

testFlushThroughputTuning

public void testFlushThroughputTuning()
                               throws Exception

Test the tuning task of PressureAwareFlushThroughputController

Throws:

Exception

testFlushControlForStripedStore

public void testFlushControlForStripedStore()
                                     throws Exception

Test the logic for striped store.

Throws:

Exception