org.apache.hadoop.hbase.replication.regionserver

Class TestReplicationSink

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.TestReplicationSink

public class TestReplicationSink
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.lang.String	baseNamespaceDir
protected static byte[]	FAM_NAME1
protected static byte[]	FAM_NAME2
protected static java.lang.String	hfileArchiveDir
protected static java.lang.String	replicationClusterId
protected static ReplicationSink	SINK
protected static Stoppable	STOPPABLE
protected static TableName	TABLE_NAME1
protected static TableName	TABLE_NAME2
protected static Table	table1
protected static Table	table2
protected static HBaseTestingUtility	TEST_UTIL

Constructor Summary

Constructors

Constructor and Description
TestReplicationSink()

Method Summary

Modifier and Type	Method and Description
void	setUp()
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testApplyDeleteBeforePut() Puts are buffered, but this tests when a delete (not-buffered) is applied before the actual Put that creates it.
void	testBatchSink() Insert a whole batch of entries
void	testMixedDeletes() Insert then do different types of deletes
void	testMixedPutDelete() Insert a mix of puts and deletes
void	testMixedPutTables() Insert to 2 different tables
void	testReplicateEntriesForHFiles() Test replicateEntries with a bulk load entry for 25 HFiles

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

TEST_UTIL

protected static final HBaseTestingUtility TEST_UTIL

SINK

protected static ReplicationSink SINK

TABLE_NAME1

protected static final TableName TABLE_NAME1

TABLE_NAME2

protected static final TableName TABLE_NAME2

FAM_NAME1

protected static final byte[] FAM_NAME1

FAM_NAME2

protected static final byte[] FAM_NAME2

table1

protected static Table table1

STOPPABLE

protected static Stoppable STOPPABLE

table2

protected static Table table2

baseNamespaceDir

protected static java.lang.String baseNamespaceDir

hfileArchiveDir

protected static java.lang.String hfileArchiveDir

replicationClusterId

protected static java.lang.String replicationClusterId

Constructor Detail

TestReplicationSink

public TestReplicationSink()

Method Detail

setUpBeforeClass

public static void setUpBeforeClass()
                             throws java.lang.Exception

Throws:

java.lang.Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws java.lang.Exception

Throws:

java.lang.Exception

setUp

public void setUp()
           throws java.lang.Exception

Throws:

java.lang.Exception

testBatchSink

public void testBatchSink()
                   throws java.lang.Exception

Insert a whole batch of entries

Throws:

java.lang.Exception

testMixedPutDelete

public void testMixedPutDelete()
                        throws java.lang.Exception

Insert a mix of puts and deletes

Throws:

java.lang.Exception

testMixedPutTables

public void testMixedPutTables()
                        throws java.lang.Exception

Insert to 2 different tables

Throws:

java.lang.Exception

testMixedDeletes

public void testMixedDeletes()
                      throws java.lang.Exception

Insert then do different types of deletes

Throws:

java.lang.Exception

testApplyDeleteBeforePut

public void testApplyDeleteBeforePut()
                              throws java.lang.Exception

Puts are buffered, but this tests when a delete (not-buffered) is applied before the actual Put that creates it.

Throws:

java.lang.Exception

testReplicateEntriesForHFiles

public void testReplicateEntriesForHFiles()
                                   throws java.lang.Exception

Test replicateEntries with a bulk load entry for 25 HFiles

Throws:

java.lang.Exception