org.apache.hadoop.hbase.wal

Class TestWALFiltering

java.lang.Object

org.apache.hadoop.hbase.wal.TestWALFiltering

public class TestWALFiltering
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
private static byte[]	CF1
private static byte[]	CF2
static HBaseClassTestRule	CLASS_RULE
private static byte[][]	FAMILIES
private static int	NUM_RS
private static org.apache.hadoop.hbase.TableName	TABLE_NAME
private HBaseTestingUtility	TEST_UTIL

Constructor Summary

Constructors

Constructor and Description
TestWALFiltering()

Method Summary

Modifier and Type	Method and Description
private void	fillTable()
private void	flushAllRegions(int rsId)
private List<byte[]>	getRegionsByServer(int rsId)
private org.apache.hadoop.hbase.regionserver.HRegionServer	getRegionServer(int rsId)
void	setUp()
void	tearDown()
void	testFlushedSequenceIdsSentToHMaster()

Methods inherited from class java.lang.Object

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

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

NUM_RS

private static final int NUM_RS

See Also:

Constant Field Values

TABLE_NAME

private static final org.apache.hadoop.hbase.TableName TABLE_NAME

CF1

private static final byte[] CF1

CF2

private static final byte[] CF2

FAMILIES

private static final byte[][] FAMILIES

TEST_UTIL

private HBaseTestingUtility TEST_UTIL

Constructor Detail

TestWALFiltering

public TestWALFiltering()

Method Detail

setUp

public void setUp()
           throws Exception

Throws:

Exception

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

fillTable

private void fillTable()
                throws IOException,
                       InterruptedException

Throws:

IOException

InterruptedException

testFlushedSequenceIdsSentToHMaster

public void testFlushedSequenceIdsSentToHMaster()
                                         throws IOException,
                                                InterruptedException,
                                                org.apache.hbase.thirdparty.com.google.protobuf.ServiceException,
                                                com.google.protobuf.ServiceException

Throws:

IOException

InterruptedException

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

getRegionsByServer

private List<byte[]> getRegionsByServer(int rsId)
                                 throws IOException

Throws:

IOException

getRegionServer

private org.apache.hadoop.hbase.regionserver.HRegionServer getRegionServer(int rsId)

flushAllRegions

private void flushAllRegions(int rsId)
                      throws com.google.protobuf.ServiceException,
                             org.apache.hbase.thirdparty.com.google.protobuf.ServiceException,
                             IOException

Throws:

com.google.protobuf.ServiceException

IOException