Class TestRegionReplicationForWriteException
java.lang.Object
org.apache.hadoop.hbase.regionserver.regionreplication.TestRegionReplicationForWriteException
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic final classstatic classstatic classstatic class -
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final HBaseClassTestRuleprivate static final byte[]private static final HBaseTestingUtilprivate static final intprivate static final byte[]private static org.apache.hadoop.hbase.TableNameprivate static booleanprivate static booleanprivate static final longprivate static final String -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate static booleancheckReplica(org.apache.hadoop.hbase.client.Table table, byte[] fam, byte[] qual, byte[] rowKey, byte[] expectValue, int replicaId) static voidsetUp()private org.apache.hadoop.hbase.regionserver.regionreplication.RegionReplicationSinksetUpSpiedRegionReplicationSink(org.apache.hadoop.hbase.regionserver.regionreplication.RegionReplicationSink regionReplicationSink, TestRegionReplicationForWriteException.HRegionForTest primaryRegion, AtomicInteger counter) static voidtearDown()voidThis 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
-