Package org.apache.hadoop.hbase.client

Class TestMvccConsistentScanner

java.lang.Object

org.apache.hadoop.hbase.client.TestMvccConsistentScanner

public class TestMvccConsistentScanner
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private static final byte[]	CF
static final HBaseClassTestRule	CLASS_RULE
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
org.junit.rules.TestName	testName
private static final HBaseTestingUtility	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()
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

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

UTIL

private static final HBaseTestingUtility 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

testName

public org.junit.rules.TestName testName

tableName

private org.apache.hadoop.hbase.TableName tableName

Constructor Details

TestMvccConsistentScanner

public TestMvccConsistentScanner()

Method Details

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

setUp

public void setUp()
           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

public void testRowAtomic()
                   throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testCrossRowAtomicInRegion

public void testCrossRowAtomicInRegion()
                                throws IOException,
InterruptedException

Throws:

IOException

InterruptedException