Package org.apache.hadoop.hbase.regionserver

Class TestMultiLogThreshold

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestMultiLogThreshold

@Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
public class TestMultiLogThreshold
extends Object

Tests logging of large batch commands via Multi. Tests are fast, but uses a mini-cluster (to test via "Multi" commands) so classified as MediumTests

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static enum	TestMultiLogThreshold.ActionType
private final class	TestMultiLogThreshold.LevelAndMessage

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.logging.log4j.core.Appender	appender
private org.apache.hadoop.conf.Configuration	conf
private BlockingDeque<TestMultiLogThreshold.LevelAndMessage>	logs
private static final org.apache.hadoop.hbase.TableName	NAME
private final boolean	rejectLargeBatchOp
private org.apache.hadoop.hbase.regionserver.HRegionServer	rs
private org.apache.hadoop.hbase.regionserver.RSRpcServices	services
private static final byte[]	TEST_FAM
private int	threshold
private HBaseTestingUtil	util

Constructor Summary

Constructors

Constructor	Description
TestMultiLogThreshold(boolean rejectLargeBatchOp)

Method Summary

Modifier and Type	Method	Description
private void	assertLogBatchWarnings(boolean expected)
static Stream<org.junit.jupiter.params.provider.Arguments>	parameters()
private void	sendMultiRequest(int rows, TestMultiLogThreshold.ActionType actionType)	Sends a multi request with a certain amount of rows, will populate Multi command with either "rows" number of RegionActions with one Action each or one RegionAction with "rows" number of Actions
void	setupTest()
void	tearDown()
void	testMultiLogThresholdRegionActions()

Methods inherited from class java.lang.Object

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

Field Details

NAME

private static final org.apache.hadoop.hbase.TableName NAME

TEST_FAM

private static final byte[] TEST_FAM

util

private HBaseTestingUtil util

conf

private org.apache.hadoop.conf.Configuration conf

threshold

private int threshold

rs

private org.apache.hadoop.hbase.regionserver.HRegionServer rs

services

private org.apache.hadoop.hbase.regionserver.RSRpcServices services

appender

private org.apache.logging.log4j.core.Appender appender

rejectLargeBatchOp

private final boolean rejectLargeBatchOp

logs

private BlockingDeque<TestMultiLogThreshold.LevelAndMessage> logs

Constructor Details

TestMultiLogThreshold

public TestMultiLogThreshold(boolean rejectLargeBatchOp)

Method Details

parameters

public static Stream<org.junit.jupiter.params.provider.Arguments> parameters()

setupTest

@BeforeEach
public void setupTest()
               throws Exception

Throws:

Exception

tearDown

@AfterEach
public void tearDown()
              throws Exception

Throws:

Exception

sendMultiRequest

private void sendMultiRequest(int rows,
 TestMultiLogThreshold.ActionType actionType)
                       throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException,
IOException

Sends a multi request with a certain amount of rows, will populate Multi command with either "rows" number of RegionActions with one Action each or one RegionAction with "rows" number of Actions

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

IOException

assertLogBatchWarnings

private void assertLogBatchWarnings(boolean expected)

testMultiLogThresholdRegionActions

@TestTemplate
public void testMultiLogThresholdRegionActions()
                                        throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException,
IOException

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

IOException