JavaScript is disabled on your browser.
-
Field Summary
Fields Modifier and Type Field and Description static HBaseClassTestRuleCLASS_RULEprivate static org.apache.hadoop.conf.Configurationconforg.junit.rules.TestNamecurrentTestprivate static org.apache.hadoop.fs.FileSystemfsprivate static org.slf4j.LoggerLOGprivate org.apache.hadoop.hbase.regionserver.MultiVersionConcurrencyControlmvccprivate static HBaseTestingUtilityTEST_UTIL
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method and Description private voidaddEdits(org.apache.hadoop.hbase.wal.WAL log,
org.apache.hadoop.hbase.client.RegionInfo hri,
org.apache.hadoop.hbase.client.TableDescriptor htd,
int times,
NavigableMap<byte[],Integer> scopes)protected voidflushRegion(org.apache.hadoop.hbase.wal.WAL wal,
byte[] regionEncodedName,
Set<byte[]> flushedFamilyNames)helper method to simulate region flush for a WAL.
(package private) static StringgetName()(package private) org.apache.hadoop.hbase.wal.WALKeyImplgetWalKey(byte[] info,
org.apache.hadoop.hbase.TableName tableName,
long timestamp,
NavigableMap<byte[],Integer> scopes)used by TestDefaultWALProviderWithHLogKey
voidsetMembershipDedups()Ensure that we can use Set.add to deduplicate WALs
voidsetUp()static voidsetUpBeforeClass()static voidtearDownAfterClass()voidtestConcurrentWrites()Write to a log file with three concurrent threads and verifying all data is written.
voidtestGetServerNameFromWALDirectoryName()voidtestLogCleaning()voidtestWALArchiving()Tests wal archiving by adding data, doing flushing/rolling and checking we archive old logs
and also don't archive "live logs" (that is, a log with un-flushed entries).
-
Method Detail
-
addEdits
private void addEdits(org.apache.hadoop.hbase.wal.WAL log, org.apache.hadoop.hbase.client.RegionInfo hri, org.apache.hadoop.hbase.client.TableDescriptor htd, int times, NavigableMap<byte[],Integer> scopes) throws IOException
- Throws:
IOException
-
getWalKey
org.apache.hadoop.hbase.wal.WALKeyImpl getWalKey(byte[] info, org.apache.hadoop.hbase.TableName tableName, long timestamp, NavigableMap<byte[],Integer> scopes)
used by TestDefaultWALProviderWithHLogKey
- Parameters:
scopes-
-
flushRegion
protected void flushRegion(org.apache.hadoop.hbase.wal.WAL wal, byte[] regionEncodedName, Set<byte[]> flushedFamilyNames)
helper method to simulate region flush for a WAL.
- Parameters:
wal-regionEncodedName-
-
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.
