public class TestRegionLocationCaching extends Object
Modifier and Type | Field and Description |
---|---|
static HBaseClassTestRule |
CLASS_RULE |
private static byte[] |
FAMILY |
private static int |
PER_REGIONSERVER_QUEUE_SIZE |
private static byte[] |
QUALIFIER |
private static int |
SLAVES |
private static org.apache.hadoop.hbase.TableName |
TABLE_NAME |
private static HBaseTestingUtility |
TEST_UTIL |
Constructor and Description |
---|
TestRegionLocationCaching() |
Modifier and Type | Method and Description |
---|---|
private static void |
checkExistence(org.apache.hadoop.hbase.TableName tableName,
byte[] row,
byte[] family,
byte[] qualifier)
Method to check whether the passed row exists in the given table
|
private void |
checkRegionLocationIsCached(org.apache.hadoop.hbase.TableName tableName,
org.apache.hadoop.hbase.client.Connection conn)
Method to check whether the cached region location is non-empty for the given table.
|
static void |
setUpBeforeClass() |
static void |
tearDownAfterClass() |
void |
testCachingForHTableMultiplexerMultiPut() |
void |
testCachingForHTableMultiplexerSinglePut() |
void |
testCachingForHTableMultiPut() |
void |
testCachingForHTableSinglePut() |
public static final HBaseClassTestRule CLASS_RULE
private static final HBaseTestingUtility TEST_UTIL
private static int SLAVES
private static int PER_REGIONSERVER_QUEUE_SIZE
private static org.apache.hadoop.hbase.TableName TABLE_NAME
private static byte[] FAMILY
private static byte[] QUALIFIER
public TestRegionLocationCaching()
public static void setUpBeforeClass() throws Exception
Exception
public static void tearDownAfterClass() throws Exception
Exception
public void testCachingForHTableMultiplexerSinglePut() throws Exception
Exception
public void testCachingForHTableMultiplexerMultiPut() throws Exception
Exception
public void testCachingForHTableSinglePut() throws Exception
Exception
public void testCachingForHTableMultiPut() throws Exception
Exception
private void checkRegionLocationIsCached(org.apache.hadoop.hbase.TableName tableName, org.apache.hadoop.hbase.client.Connection conn) throws InterruptedException, IOException
InterruptedException
IOException
private static void checkExistence(org.apache.hadoop.hbase.TableName tableName, byte[] row, byte[] family, byte[] qualifier) throws Exception
Exception
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.