Package 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	Description
private static final byte[]	CF1
private static final byte[]	CF2
static final HBaseClassTestRule	CLASS_RULE
private static final byte[][]	FAMILIES
private static final int	NUM_RS
private static final org.apache.hadoop.hbase.TableName	TABLE_NAME
private HBaseTestingUtil	TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
TestWALFiltering()

Method Summary

Modifier and Type	Method	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 Details

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 HBaseTestingUtil TEST_UTIL

Constructor Details

TestWALFiltering

public TestWALFiltering()

Method Details

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,
org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Throws:

IOException

InterruptedException

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

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 org.apache.hbase.thirdparty.com.google.protobuf.ServiceException,
org.apache.hbase.thirdparty.com.google.protobuf.ServiceException,
IOException

Throws:

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

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

IOException