public class TestPostIncrementAndAppendBeforeWAL extends Object
RegionObserver.postIncrementBeforeWAL(ObserverContext, Mutation, List)
and
RegionObserver.postAppendBeforeWAL(ObserverContext, Mutation, List)
. These methods may
change the cells which will be applied to memstore and WAL. So add unit test for the case which
change the cell's column family.Modifier and Type | Class and Description |
---|---|
static class |
TestPostIncrementAndAppendBeforeWAL.ChangeCellWithDifferntColumnFamilyObserver |
static class |
TestPostIncrementAndAppendBeforeWAL.ChangeCellWithNotExistColumnFamilyObserver |
Modifier and Type | Field and Description |
---|---|
private static String |
CF_NOT_EXIST |
private static byte[] |
CF_NOT_EXIST_BYTES |
private static String |
CF1 |
private static byte[] |
CF1_BYTES |
private static String |
CF2 |
private static byte[] |
CF2_BYTES |
static HBaseClassTestRule |
CLASS_RULE |
private static org.apache.hadoop.hbase.client.Connection |
connection |
private static byte[] |
CQ1 |
private static byte[] |
CQ2 |
private static org.slf4j.Logger |
LOG |
org.junit.rules.TestName |
name |
private static byte[] |
ROW |
private static HBaseTestingUtility |
UTIL |
private static byte[] |
VALUE |
Constructor and Description |
---|
TestPostIncrementAndAppendBeforeWAL() |
Modifier and Type | Method and Description |
---|---|
private void |
createTableWithCoprocessor(org.apache.hadoop.hbase.TableName tableName,
String coprocessor) |
static void |
setupBeforeClass() |
static void |
tearDownAfterClass() |
void |
testChangeCellWithDifferntColumnFamily() |
void |
testChangeCellWithNotExistColumnFamily() |
public static final HBaseClassTestRule CLASS_RULE
public org.junit.rules.TestName name
private static final org.slf4j.Logger LOG
private static final HBaseTestingUtility UTIL
private static org.apache.hadoop.hbase.client.Connection connection
private static final byte[] ROW
private static final String CF1
private static final byte[] CF1_BYTES
private static final String CF2
private static final byte[] CF2_BYTES
private static final String CF_NOT_EXIST
private static final byte[] CF_NOT_EXIST_BYTES
private static final byte[] CQ1
private static final byte[] CQ2
private static final byte[] VALUE
public TestPostIncrementAndAppendBeforeWAL()
public static void setupBeforeClass() throws Exception
Exception
public static void tearDownAfterClass() throws Exception
Exception
private void createTableWithCoprocessor(org.apache.hadoop.hbase.TableName tableName, String coprocessor) throws IOException
IOException
public void testChangeCellWithDifferntColumnFamily() throws Exception
Exception
public void testChangeCellWithNotExistColumnFamily() throws Exception
Exception
Copyright © 2007–2021 The Apache Software Foundation. All rights reserved.