Package org.apache.hadoop.hbase.quotas

Class TestFileArchiverNotifierImpl

java.lang.Object

org.apache.hadoop.hbase.quotas.TestFileArchiverNotifierImpl

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

Test class for FileArchiverNotifierImpl.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static interface	TestFileArchiverNotifierImpl.IOThrowingRunnable

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.hbase.client.Admin	admin
private org.apache.hadoop.conf.Configuration	conf
private org.apache.hadoop.hbase.client.Connection	conn
private static final AtomicLong	COUNTER
private org.apache.hadoop.fs.FileSystem	fs
private SpaceQuotaHelperForTests	helper
private static final HBaseTestingUtil	TEST_UTIL
private String	testName

Constructor Summary

Constructors

Constructor	Description
TestFileArchiverNotifierImpl()

Method Summary

Modifier and Type	Method	Description
private long	count(org.apache.hadoop.hbase.client.Table t)
private <K, V> Map.Entry<K,V>	entry(K k, V v)
private long	extractSnapshotSize(org.apache.hadoop.hbase.client.Table quotaTable, org.apache.hadoop.hbase.TableName tn, String snapshot)
private Set<String>	getFilesReferencedBySnapshot(String snapshotName)
void	setup(org.junit.jupiter.api.TestInfo testInfo)
static void	setUp()
static void	tearDown()
void	testIncrementalFileArchiving()
void	testParseOldNamespaceSnapshotSize()
void	testSnapshotSizePersistence()
private void	verify(org.apache.hadoop.hbase.client.Table t, TestFileArchiverNotifierImpl.IOThrowingRunnable test)

Methods inherited from class java.lang.Object

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

Field Details

TEST_UTIL

private static final HBaseTestingUtil TEST_UTIL

COUNTER

private static final AtomicLong COUNTER

conn

private org.apache.hadoop.hbase.client.Connection conn

admin

private org.apache.hadoop.hbase.client.Admin admin

helper

private SpaceQuotaHelperForTests helper

fs

private org.apache.hadoop.fs.FileSystem fs

conf

private org.apache.hadoop.conf.Configuration conf

testName

private String testName

Constructor Details

TestFileArchiverNotifierImpl

public TestFileArchiverNotifierImpl()

Method Details

setUp

@BeforeAll
public static void setUp()
                  throws Exception

Throws:

Exception

tearDown

@AfterAll
public static void tearDown()
                     throws Exception

Throws:

Exception

setup

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

Throws:

Exception

testSnapshotSizePersistence

@Test
public void testSnapshotSizePersistence()
                                 throws IOException

Throws:

IOException

testIncrementalFileArchiving

@Test
public void testIncrementalFileArchiving()
                                  throws Exception

Throws:

Exception

testParseOldNamespaceSnapshotSize

@Test
public void testParseOldNamespaceSnapshotSize()
                                       throws Exception

Throws:

Exception

count

private long count(org.apache.hadoop.hbase.client.Table t)
            throws IOException

Throws:

IOException

extractSnapshotSize

private long extractSnapshotSize(org.apache.hadoop.hbase.client.Table quotaTable,
 org.apache.hadoop.hbase.TableName tn,
 String snapshot)
                          throws IOException

Throws:

IOException

verify

private void verify(org.apache.hadoop.hbase.client.Table t,
 TestFileArchiverNotifierImpl.IOThrowingRunnable test)
             throws IOException

Throws:

IOException

getFilesReferencedBySnapshot

private Set<String> getFilesReferencedBySnapshot(String snapshotName)
                                          throws IOException

Throws:

IOException

entry

private <K,
V> Map.Entry<K,V> entry(K k,
 V v)