Package org.apache.hadoop.hbase.regionserver.throttle

Class TestFlushWithThroughputController

java.lang.Object

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

@Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestFlushWithThroughputController
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private static final double	EPSILON
private final byte[]	family
private HBaseTestingUtil	hbtu
private static final org.slf4j.Logger	LOG
private final byte[]	qualifier
private org.apache.hadoop.hbase.TableName	tableName
private String	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(org.junit.jupiter.api.TestInfo testInfo)
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

LOG

private static final org.slf4j.Logger LOG

EPSILON

private static final double EPSILON

See Also:

• Constant Field Values

hbtu

private HBaseTestingUtil hbtu

testName

private String 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

@BeforeEach
public void setUp(org.junit.jupiter.api.TestInfo testInfo)

tearDown

@AfterEach
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

@Test
public void testFlushControl()
                      throws Exception

Throws:

Exception

testFlushThroughputTuning

@Test
public void testFlushThroughputTuning()
                               throws Exception

Test the tuning task of PressureAwareFlushThroughputController

Throws:

Exception

testFlushControlForStripedStore

@Test
public void testFlushControlForStripedStore()
                                     throws Exception

Test the logic for striped store.

Throws:

Exception