Package 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	Description
static final HBaseClassTestRule	CLASS_RULE
private static final double	EPSILON
private final byte[]	family
private HBaseTestingUtility	hbtu
private static final org.slf4j.Logger	LOG
private final byte[]	qualifier
private org.apache.hadoop.hbase.TableName	tableName
org.junit.rules.TestName	testName

Constructor Summary

Constructors

Constructor	Description
TestFlushWithThroughputController()

Method Summary

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

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 Details

TestFlushWithThroughputController

public TestFlushWithThroughputController()

Method Details

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