Class TestPerTableCFReplication
java.lang.Object
org.apache.hadoop.hbase.replication.TestPerTableCFReplication
@Tag("org.apache.hadoop.hbase.testclassification.ReplicationTests") @Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestPerTableCFReplication
extends Object
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate static org.apache.hadoop.conf.Configurationprivate static org.apache.hadoop.conf.Configurationprivate static org.apache.hadoop.conf.Configurationprivate static final byte[]private static final byte[]private static final byte[]private static final org.slf4j.Loggerprivate static final intprivate static final byte[]private static final byte[]private static final longprivate static org.apache.hadoop.hbase.client.TableDescriptorprivate static final org.apache.hadoop.hbase.TableNameprivate static org.apache.hadoop.hbase.client.TableDescriptorprivate static final org.apache.hadoop.hbase.TableNameprivate static org.apache.hadoop.hbase.client.TableDescriptorprivate static final org.apache.hadoop.hbase.TableNameprivate final TableNameTestExtensionprivate static HBaseTestingUtilprivate static HBaseTestingUtilprivate static HBaseTestingUtilprivate static final byte[] -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate voiddeleteAndWaitWithFamily(byte[] row, byte[] fam, org.apache.hadoop.hbase.client.Table source, org.apache.hadoop.hbase.client.Table... targets) private voidensureRowNotReplicated(byte[] row, byte[] fam, org.apache.hadoop.hbase.client.Table... tables) private voidputAndWaitWithFamily(byte[] row, byte[] fam, org.apache.hadoop.hbase.client.Table source, org.apache.hadoop.hbase.client.Table... targets) static voidstatic voidvoidvoidvoid
-
Field Details
-
LOG
-
conf1
-
conf2
-
conf3
-
utility1
-
utility2
-
utility3
-
SLEEP_TIME
- See Also:
-
NB_RETRIES
- See Also:
-
tabAName
-
tabBName
-
tabCName
-
f1Name
-
f2Name
-
f3Name
-
row1
-
row2
-
val
-
tabA
-
tabB
-
tabC
-
tableNameExt
-
-
Constructor Details
-
TestPerTableCFReplication
public TestPerTableCFReplication()
-
-
Method Details
-
setUpBeforeClass
- Throws:
Exception
-
tearDownAfterClass
- Throws:
Exception
-
testParseTableCFsFromConfig
-
testTableCFsHelperConverter
-
testPerTableCFReplication
- Throws:
Exception
-
ensureRowNotReplicated
private void ensureRowNotReplicated(byte[] row, byte[] fam, org.apache.hadoop.hbase.client.Table... tables) throws IOException - Throws:
IOException
-
deleteAndWaitWithFamily
private void deleteAndWaitWithFamily(byte[] row, byte[] fam, org.apache.hadoop.hbase.client.Table source, org.apache.hadoop.hbase.client.Table... targets) throws Exception - Throws:
Exception
-
putAndWaitWithFamily
private void putAndWaitWithFamily(byte[] row, byte[] fam, org.apache.hadoop.hbase.client.Table source, org.apache.hadoop.hbase.client.Table... targets) throws Exception - Throws:
Exception
-