Package org.apache.hadoop.hbase.regionserver

Class TestMultiLogThreshold

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestMultiLogThreshold

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
static final HBaseClassTestRule	CLASS_RULE
private org.apache.hadoop.conf.Configuration	conf
private BlockingDeque<TestMultiLogThreshold.LevelAndMessage>	logs
private static final org.apache.hadoop.hbase.TableName	NAME
static 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 HBaseTestingUtility	util

Constructor Summary

Constructors

Constructor	Description
TestMultiLogThreshold()

Method Summary

Modifier and Type	Method	Description
private void	assertLogBatchWarnings(boolean expected)
static List<Object[]>	params()
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

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

NAME

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

TEST_FAM

private static final byte[] TEST_FAM

util

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

public static boolean rejectLargeBatchOp

logs

private BlockingDeque<TestMultiLogThreshold.LevelAndMessage> logs

Constructor Details

TestMultiLogThreshold

public TestMultiLogThreshold()

Method Details

params

public static List<Object[]> params()

setupTest

public void setupTest()
               throws Exception

Throws:

Exception

tearDown

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

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

Throws:

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

IOException