Package org.apache.hadoop.hbase.replication.regionserver

Class TestBasicWALEntryStreamFSHLog

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.WALEntryStreamTestBase

org.apache.hadoop.hbase.replication.regionserver.TestBasicWALEntryStream

org.apache.hadoop.hbase.replication.regionserver.TestBasicWALEntryStreamFSHLog

@Tag("org.apache.hadoop.hbase.testclassification.ReplicationTests") @Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
public class TestBasicWALEntryStreamFSHLog
extends TestBasicWALEntryStream

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.replication.regionserver.TestBasicWALEntryStream

TestBasicWALEntryStream.FailingWALEntryFilter

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.replication.regionserver.WALEntryStreamTestBase

WALEntryStreamTestBase.PathWatcher, WALEntryStreamTestBase.WALEntryStreamWithRetries

Field Summary

Fields inherited from class org.apache.hadoop.hbase.replication.regionserver.TestBasicWALEntryStream

isCompressionEnabled

Fields inherited from class org.apache.hadoop.hbase.replication.regionserver.WALEntryStreamTestBase

cluster, CONF, fakeWalGroupId, family, fs, info, log, logQueue, mvcc, pathWatcher, qualifier, scopes, tableName, TEST_TIMEOUT_MS, TEST_UTIL, testName

Constructor Summary

Constructors

Constructor	Description
TestBasicWALEntryStreamFSHLog(boolean isCompressionEnabled)

Method Summary

Modifier and Type	Method	Description
static Stream<org.junit.jupiter.params.provider.Arguments>	parameters()
static void	setUpBeforeClass()

Methods inherited from class org.apache.hadoop.hbase.replication.regionserver.TestBasicWALEntryStream

setUp, testAppendsWithRolls, testCleanClosedWALs, testEmptyStream, testEOFExceptionForRecoveredQueue, testEOFExceptionForRecoveredQueueWithMultipleLogs, testEOFExceptionInOldWALsDirectory, testLogRollWhileStreaming, testNewEntriesWhileStreaming, testPosition, testPositionResetOnFileSwitchWithRetryableFilter, testReadBeyondCommittedLength, testReplicationSourceWALReader, testReplicationSourceWALReaderDisabled, testReplicationSourceWALReaderRecovered, testReplicationSourceWALReaderWithFailingFilter, testReplicationSourceWALReaderWithPartialWALEntryFailingFilter, testReplicationSourceWALReaderWrongPosition, testResumeStreamingFromPosition, testSizeOfLogQueue, testWALEntryStreamEOFRightAfterHeader, testWALKeySerialization

Methods inherited from class org.apache.hadoop.hbase.replication.regionserver.WALEntryStreamTestBase

appendToLog, appendToLogAndSync, appendToLogAndSync, getWALEdits, initWAL, setUp, startCluster, tearDown, tearDownAfterClass

Methods inherited from class java.lang.Object

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

Constructor Details

TestBasicWALEntryStreamFSHLog

public TestBasicWALEntryStreamFSHLog(boolean isCompressionEnabled)

Method Details

parameters

public static Stream<org.junit.jupiter.params.provider.Arguments> parameters()

setUpBeforeClass

@BeforeAll
public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception