Package org.apache.hadoop.hbase.client

Class TestMvccConsistentScanner

java.lang.Object

org.apache.hadoop.hbase.client.TestMvccConsistentScanner

@Tag("org.apache.hadoop.hbase.testclassification.MediumTests") @Tag("org.apache.hadoop.hbase.testclassification.ClientTests")
public class TestMvccConsistentScanner
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private static final byte[]	CF
private static org.apache.hadoop.hbase.client.Connection	CONN
private static final byte[]	CQ1
private static final byte[]	CQ2
private static final byte[]	CQ3
private org.apache.hadoop.hbase.TableName	tableName
private static final HBaseTestingUtil	UTIL

Constructor Summary

Constructors

Constructor	Description
TestMvccConsistentScanner()

Method Summary

Modifier and Type	Method	Description
private void	move()
private void	put(byte[] row, byte[] cq, byte[] value)
void	setUp(org.junit.jupiter.api.TestInfo testInfo)
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testCrossRowAtomicInRegion()
void	testRowAtomic()

Methods inherited from class java.lang.Object

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

Field Details

UTIL

private static final HBaseTestingUtil UTIL

CONN

private static org.apache.hadoop.hbase.client.Connection CONN

CF

private static final byte[] CF

CQ1

private static final byte[] CQ1

CQ2

private static final byte[] CQ2

CQ3

private static final byte[] CQ3

tableName

private org.apache.hadoop.hbase.TableName tableName

Constructor Details

TestMvccConsistentScanner

public TestMvccConsistentScanner()

Method Details

setUpBeforeClass

@BeforeAll
public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

@AfterAll
public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

setUp

@BeforeEach
public void setUp(org.junit.jupiter.api.TestInfo testInfo)
           throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

put

private void put(byte[] row,
 byte[] cq,
 byte[] value)
          throws IOException

Throws:

IOException

move

private void move()
           throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testRowAtomic

@Test
public void testRowAtomic()
                   throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testCrossRowAtomicInRegion

@Test
public void testCrossRowAtomicInRegion()
                                throws IOException,
InterruptedException

Throws:

IOException

InterruptedException