Package org.apache.hadoop.hbase.replication

Class TestVerifyReplicationRecompareRunnable

java.lang.Object

org.apache.hadoop.hbase.replication.TestVerifyReplicationRecompareRunnable

@Tag("org.apache.hadoop.hbase.testclassification.ReplicationTests") @Tag("org.apache.hadoop.hbase.testclassification.SmallTests")
@ExtendWith(org.mockito.junit.jupiter.MockitoExtension.class)
public class TestVerifyReplicationRecompareRunnable
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.mapreduce.Mapper.Context	context
private org.apache.hadoop.hbase.client.Table	replicatedTable
private org.apache.hadoop.hbase.client.Table	sourceTable

Constructor Summary

Constructors

Constructor	Description
TestVerifyReplicationRecompareRunnable()

Method Summary

Modifier and Type	Method	Description
(package private) static byte[]	genBytes()
(package private) static org.apache.hadoop.hbase.client.Result	genResult(int cols)
void	itHandlesExceptionOnRecompare()
void	itRecomparesBadRow()
void	itRecomparesGoodRow()
void	setUp()

Methods inherited from class java.lang.Object

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

Field Details

sourceTable

@Mock
private org.apache.hadoop.hbase.client.Table sourceTable

replicatedTable

@Mock
private org.apache.hadoop.hbase.client.Table replicatedTable

context

@Mock
private org.apache.hadoop.mapreduce.Mapper.Context context

Constructor Details

TestVerifyReplicationRecompareRunnable

public TestVerifyReplicationRecompareRunnable()

Method Details

genResult

static org.apache.hadoop.hbase.client.Result genResult(int cols)

genBytes

static byte[] genBytes()

setUp

@BeforeEach
public void setUp()

itRecomparesGoodRow

@Test
public void itRecomparesGoodRow()
                         throws IOException

Throws:

IOException

itRecomparesBadRow

@Test
public void itRecomparesBadRow()
                        throws IOException

Throws:

IOException

itHandlesExceptionOnRecompare

@Test
public void itHandlesExceptionOnRecompare()
                                   throws IOException

Throws:

IOException