public class TestReplicasClient extends Object
TestRegionServerNoMaster
.Modifier and Type | Class and Description |
---|---|
static class |
TestReplicasClient.SlowMeCopro
This copro is used to synchronize the tests.
|
Modifier and Type | Field and Description |
---|---|
static HBaseClassTestRule |
CLASS_RULE |
private static byte[] |
f |
private static org.apache.hadoop.hbase.client.RegionInfo |
hriPrimary |
private static org.apache.hadoop.hbase.client.RegionInfo |
hriSecondary |
private static HBaseTestingUtil |
HTU |
private static org.slf4j.Logger |
LOG |
private static int |
REFRESH_PERIOD |
private static byte[] |
row |
private org.apache.hadoop.hbase.client.Table |
table |
private static org.apache.hadoop.hbase.TableName |
TABLE_NAME |
Constructor and Description |
---|
TestReplicasClient() |
Modifier and Type | Method and Description |
---|---|
void |
after() |
static void |
afterClass() |
void |
before() |
static void |
beforeClass() |
private void |
checkRegionIsClosed(String encodedRegionName) |
private void |
checkRegionIsOpened(org.apache.hadoop.hbase.client.RegionInfo hri) |
private void |
closeRegion(org.apache.hadoop.hbase.client.RegionInfo hri) |
private void |
flushRegion(org.apache.hadoop.hbase.client.RegionInfo regionInfo) |
private org.apache.hadoop.hbase.regionserver.HRegionServer |
getRS() |
private boolean |
isRegionOpened(org.apache.hadoop.hbase.client.RegionInfo hri) |
private void |
openRegion(org.apache.hadoop.hbase.client.RegionInfo hri) |
void |
testFlushPrimary() |
void |
testFlushSecondary() |
void |
testFlushTable() |
void |
testGetNoResultNoStaleRegionWithReplica() |
void |
testGetNoResultNotStaleSleepRegionWithReplica() |
void |
testGetNoResultStaleRegionWithReplica() |
void |
testHedgedRead() |
void |
testLocations() |
void |
testUseRegionWithoutReplica() |
void |
testUseRegionWithReplica() |
public static final HBaseClassTestRule CLASS_RULE
private static final org.slf4j.Logger LOG
private static org.apache.hadoop.hbase.TableName TABLE_NAME
private org.apache.hadoop.hbase.client.Table table
private static final byte[] row
private static org.apache.hadoop.hbase.client.RegionInfo hriPrimary
private static org.apache.hadoop.hbase.client.RegionInfo hriSecondary
private static final HBaseTestingUtil HTU
private static final byte[] f
private static final int REFRESH_PERIOD
public TestReplicasClient()
public static void beforeClass() throws Exception
Exception
public static void afterClass() throws Exception
Exception
public void before() throws IOException
IOException
public void after() throws IOException, org.apache.zookeeper.KeeperException
IOException
org.apache.zookeeper.KeeperException
private org.apache.hadoop.hbase.regionserver.HRegionServer getRS()
private void openRegion(org.apache.hadoop.hbase.client.RegionInfo hri) throws Exception
Exception
private void closeRegion(org.apache.hadoop.hbase.client.RegionInfo hri) throws Exception
Exception
private void checkRegionIsOpened(org.apache.hadoop.hbase.client.RegionInfo hri) throws Exception
Exception
private boolean isRegionOpened(org.apache.hadoop.hbase.client.RegionInfo hri) throws Exception
Exception
private void checkRegionIsClosed(String encodedRegionName) throws Exception
Exception
private void flushRegion(org.apache.hadoop.hbase.client.RegionInfo regionInfo) throws IOException
IOException
public void testUseRegionWithoutReplica() throws Exception
Exception
public void testLocations() throws Exception
Exception
public void testGetNoResultNoStaleRegionWithReplica() throws Exception
Exception
public void testGetNoResultStaleRegionWithReplica() throws Exception
Exception
public void testGetNoResultNotStaleSleepRegionWithReplica() throws Exception
Exception
public void testFlushTable() throws Exception
Exception
public void testFlushPrimary() throws Exception
Exception
public void testFlushSecondary() throws Exception
Exception
public void testUseRegionWithReplica() throws Exception
Exception
public void testHedgedRead() throws Exception
Exception
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.