Package org.apache.hadoop.hbase.wal

Class TestWALFactory

java.lang.Object

org.apache.hadoop.hbase.wal.TestWALFactory

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

WAL tests that can be reused across providers.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	TestWALFactory.BrokenWALCellCodec	A custom WALCellCodec in which we can inject failure.
(package private) static class	TestWALFactory.DumbWALActionsListener
private static class	TestWALFactory.InputStreamProxy	A proxy around FSDataInputStream which can report if close() was called.

Field Summary

Fields

Modifier and Type	Field	Description
private static org.apache.hadoop.hdfs.MiniDFSCluster	cluster
protected static org.apache.hadoop.conf.Configuration	conf
private org.apache.hadoop.hbase.ServerName	currentServername
private String	currentTestName
protected org.apache.hadoop.fs.Path	dir
protected org.apache.hadoop.fs.FileSystem	fs
protected static org.apache.hadoop.fs.Path	hbaseDir
protected static org.apache.hadoop.fs.Path	hbaseWALDir
private static final org.slf4j.Logger	LOG
protected static final HBaseTestingUtil	TEST_UTIL
protected org.apache.hadoop.hbase.wal.WALFactory	wals

Constructor Summary

Constructors

Constructor	Description
TestWALFactory()

Method Summary

Modifier and Type	Method	Description
void	Broken_testSync()	Test new HDFS-265 sync.
void	canCloseSingleton()
void	setUp(org.junit.jupiter.api.TestInfo testInfo)
static void	setUpBeforeClass()
void	tearDown()
static void	tearDownAfterClass()
void	testAppend()
void	testAppendClose()
void	testCustomMetaProvider()
void	testCustomProvider()
void	testCustomReplicationProvider()
void	testDefaultProvider()
void	testDifferentWALs()	Confirm that we will use different WALs for hbase:meta and hbase:replication
void	testEditAdd()	Tests that we can write out an edit, close, and then read it back in again.
void	testOnlySetMetaWALProvider()
void	testOnlySetWALProvider()
void	testReaderClosedOnBadCodec()
void	testSplit()	Just write multiple logs then split.
void	testVisitors()	Test that we can visit entries before they are appended
void	testWALCoprocessorLoaded()	A loaded WAL coprocessor won't break existing WAL test cases.
void	testWALProviders()
private void	verifySplits(List<org.apache.hadoop.fs.Path> splits, int howmany)

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

conf

protected static org.apache.hadoop.conf.Configuration conf

cluster

private static org.apache.hadoop.hdfs.MiniDFSCluster cluster

TEST_UTIL

protected static final HBaseTestingUtil TEST_UTIL

hbaseDir

protected static org.apache.hadoop.fs.Path hbaseDir

hbaseWALDir

protected static org.apache.hadoop.fs.Path hbaseWALDir

fs

protected org.apache.hadoop.fs.FileSystem fs

dir

protected org.apache.hadoop.fs.Path dir

wals

protected org.apache.hadoop.hbase.wal.WALFactory wals

currentServername

private org.apache.hadoop.hbase.ServerName currentServername

currentTestName

private String currentTestName

Constructor Details

TestWALFactory

public TestWALFactory()

Method Details

setUp

@BeforeEach
public void setUp(org.junit.jupiter.api.TestInfo testInfo)
           throws Exception

Throws:

Exception

tearDown

@AfterEach
public void tearDown()
              throws Exception

Throws:

Exception

setUpBeforeClass

@BeforeAll
public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

@AfterAll
public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

canCloseSingleton

@Test
public void canCloseSingleton()
                       throws IOException

Throws:

IOException

testSplit

@Test
public void testSplit()
               throws IOException

Just write multiple logs then split. Before fix for HADOOP-2283, this would fail.

Throws:

IOException

Broken_testSync

@Test
public void Broken_testSync()
                     throws Exception

Test new HDFS-265 sync.

Throws:

Exception

verifySplits

private void verifySplits(List<org.apache.hadoop.fs.Path> splits,
 int howmany)
                   throws IOException

Throws:

IOException

testAppendClose

@Test
public void testAppendClose()
                     throws Exception

Throws:

Exception

testEditAdd

@Test
public void testEditAdd()
                 throws IOException

Tests that we can write out an edit, close, and then read it back in again.

Throws:

IOException

testAppend

@Test
public void testAppend()
                throws IOException

Throws:

IOException

testVisitors

@Test
public void testVisitors()
                  throws Exception

Test that we can visit entries before they are appended

Throws:

Exception

testWALCoprocessorLoaded

@Test
public void testWALCoprocessorLoaded()
                              throws Exception

A loaded WAL coprocessor won't break existing WAL test cases.

Throws:

Exception

testWALProviders

@Test
public void testWALProviders()
                      throws IOException

Throws:

IOException

testOnlySetWALProvider

@Test
public void testOnlySetWALProvider()
                            throws IOException

Throws:

IOException

testOnlySetMetaWALProvider

@Test
public void testOnlySetMetaWALProvider()
                                throws IOException

Throws:

IOException

testDefaultProvider

@Test
public void testDefaultProvider()
                         throws IOException

Throws:

IOException

testCustomProvider

@Test
public void testCustomProvider()
                        throws IOException

Throws:

IOException

testCustomMetaProvider

@Test
public void testCustomMetaProvider()
                            throws IOException

Throws:

IOException

testCustomReplicationProvider

@Test
public void testCustomReplicationProvider()
                                   throws IOException

Throws:

IOException

testDifferentWALs

@Test
public void testDifferentWALs()
                       throws IOException

Confirm that we will use different WALs for hbase:meta and hbase:replication

Throws:

IOException

testReaderClosedOnBadCodec

@Test
public void testReaderClosedOnBadCodec()
                                throws IOException

Throws:

IOException