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

Class TestWALEntryStreamDifferentCountsAsyncFSWAL

java.lang.Object

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

org.apache.hadoop.hbase.replication.regionserver.TestWALEntryStreamDifferentCounts

org.apache.hadoop.hbase.replication.regionserver.TestWALEntryStreamDifferentCountsAsyncFSWAL

@Tag("org.apache.hadoop.hbase.testclassification.ReplicationTests") @Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestWALEntryStreamDifferentCountsAsyncFSWAL
extends TestWALEntryStreamDifferentCounts

Nested Class Summary

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.TestWALEntryStreamDifferentCounts

isCompressionEnabled, nbRows, walEditKVs

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
TestWALEntryStreamDifferentCountsAsyncFSWAL(int nbRows, int walEditKVs, 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.TestWALEntryStreamDifferentCounts

setUp, testDifferentCounts

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

TestWALEntryStreamDifferentCountsAsyncFSWAL

public TestWALEntryStreamDifferentCountsAsyncFSWAL(int nbRows,
 int walEditKVs,
 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