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

Class TestWALEntryStreamCompressionReset

java.lang.Object
org.apache.hadoop.hbase.replication.regionserver.TestWALEntryStreamCompressionReset
@Tag("org.apache.hadoop.hbase.testclassification.ReplicationTests") @Tag("org.apache.hadoop.hbase.testclassification.MediumTests") public class TestWALEntryStreamCompressionReset extends Object
Enable compression and reset the WALEntryStream while reading in ReplicationSourceWALReader.

This is used to confirm that we can work well when hitting EOFException in the middle when reading a WAL entry, when compression is enabled. See HBASE-27621 for more details.

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private static int
    END_OFFSET_OF_WAL_ENTRIES
     
    private static byte[]
    FAMILY
     
    private static org.apache.hadoop.fs.FileSystem
    FS
     
    private static String
    GROUP_ID
     
    private static org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceLogQueue
    LOG_QUEUE
     
    private static org.apache.hadoop.hbase.replication.regionserver.MetricsSource
    METRICS_SOURCE
     
    private static org.apache.hadoop.hbase.regionserver.MultiVersionConcurrencyControl
    MVCC
     
    private static org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceWALReader
    READER
     
    private static org.apache.hadoop.hbase.client.RegionInfo
    REGION_INFO
     
    private static NavigableMap<byte[],Integer>
    SCOPE
     
    private static org.apache.hadoop.hbase.replication.regionserver.ReplicationSource
    SOURCE
     
    private static org.apache.hadoop.hbase.TableName
    TABLE_NAME
     
    private static org.apache.hadoop.fs.Path
    TEMPLATE_WAL_FILE
     
    private static final HBaseTestingUtil
    UTIL
     
    private static org.apache.hadoop.fs.Path
    WAL_FILE
     
    private static long
    WAL_LENGTH
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    TestWALEntryStreamCompressionReset()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    private static org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.fs.Path,Long>
    generateWAL()
     
    static void
    setUp()
     
    static void
    tearDown()
     
    private void
    test(byte[] content, org.apache.hadoop.fs.FSDataOutputStream out)
     
    void
    testReset()
     

    Methods inherited from class java.lang.Object

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

  • Field Details

    • UTIL

      private static final HBaseTestingUtil UTIL

    • TABLE_NAME

      private static org.apache.hadoop.hbase.TableName TABLE_NAME

    • REGION_INFO

      private static org.apache.hadoop.hbase.client.RegionInfo REGION_INFO

    • FAMILY

      private static byte[] FAMILY

    • MVCC

      private static org.apache.hadoop.hbase.regionserver.MultiVersionConcurrencyControl MVCC

    • SCOPE

      private static NavigableMap<byte[],Integer> SCOPE

    • GROUP_ID

      private static String GROUP_ID

    • FS

      private static org.apache.hadoop.fs.FileSystem FS

    • SOURCE

      private static org.apache.hadoop.hbase.replication.regionserver.ReplicationSource SOURCE

    • METRICS_SOURCE

      private static org.apache.hadoop.hbase.replication.regionserver.MetricsSource METRICS_SOURCE

    • LOG_QUEUE

      private static org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceLogQueue LOG_QUEUE

    • TEMPLATE_WAL_FILE

      private static org.apache.hadoop.fs.Path TEMPLATE_WAL_FILE

    • END_OFFSET_OF_WAL_ENTRIES

      private static int END_OFFSET_OF_WAL_ENTRIES

    • WAL_FILE

      private static org.apache.hadoop.fs.Path WAL_FILE

    • WAL_LENGTH

      private static volatile long WAL_LENGTH

    • READER

      private static org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceWALReader READER

  • Constructor Details

  • Method Details