Class TestRegionReplicationForWriteException
java.lang.Object
org.apache.hadoop.hbase.regionserver.regionreplication.TestRegionReplicationForWriteException
-
Nested Class Summary
Modifier and TypeClassDescriptionstatic final class
static class
static class
static class
-
Field Summary
Modifier and TypeFieldDescriptionstatic final HBaseClassTestRule
private static final byte[]
private static final HBaseTestingUtil
private static final int
private static final byte[]
private static org.apache.hadoop.hbase.TableName
private static boolean
private static boolean
private static final long
private static final String
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprivate static boolean
checkReplica
(org.apache.hadoop.hbase.client.Table table, byte[] fam, byte[] qual, byte[] rowKey, byte[] expectValue, int replicaId) static void
setUp()
private org.apache.hadoop.hbase.regionserver.regionreplication.RegionReplicationSink
setUpSpiedRegionReplicationSink
(org.apache.hadoop.hbase.regionserver.regionreplication.RegionReplicationSink regionReplicationSink, TestRegionReplicationForWriteException.HRegionForTest primaryRegion, AtomicInteger counter) static void
tearDown()
void
This test is for HBASE-27303.
-
Field Details
-
CLASS_RULE
-
FAMILY
-
QUAL
-
HTU
-
NB_SERVERS
- See Also:
-
tableName
-
testWALTimout
-
testCP
-
timeoutMIlliseconds
- See Also:
-
USER_THREAD_NAME
-
-
Constructor Details
-
TestRegionReplicationForWriteException
-
-
Method Details
-
setUp
- Throws:
Exception
-
tearDown
- Throws:
Exception
-
testWriteException
This test is for HBASE-27303.- Throws:
Exception
-
setUpSpiedRegionReplicationSink
private org.apache.hadoop.hbase.regionserver.regionreplication.RegionReplicationSink setUpSpiedRegionReplicationSink(org.apache.hadoop.hbase.regionserver.regionreplication.RegionReplicationSink regionReplicationSink, TestRegionReplicationForWriteException.HRegionForTest primaryRegion, AtomicInteger counter) -
checkReplica
private static boolean checkReplica(org.apache.hadoop.hbase.client.Table table, byte[] fam, byte[] qual, byte[] rowKey, byte[] expectValue, int replicaId) throws IOException - Throws:
IOException
-
createTable
- Throws:
Exception
-