Package org.apache.hadoop.hbase.io.compress

Class TestCodecPool

java.lang.Object

org.apache.hadoop.hbase.io.compress.TestCodecPool

@Tag("org.apache.hadoop.hbase.testclassification.MiscTests") @Tag("org.apache.hadoop.hbase.testclassification.SmallTests")
public class TestCodecPool
extends Object

Along with CodecPool, this is copied from the class of the same name in hadoop-common. Modified to accommodate changes to HBase's CodecPool.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) org.apache.hadoop.io.compress.DefaultCodec	codec
private final String	LEASE_COUNT_ERR

Constructor Summary

Constructors

Constructor	Description
TestCodecPool()

Method Summary

Modifier and Type	Method	Description
static void	beforeClass()
void	setup()
void	testCompressorNotReturnSameInstance()
void	testCompressorPoolCounts()
void	testDecompressorNotReturnSameInstance()
void	testDecompressorPoolCounts()
void	testDoNotPoolDecompressorNotUseableAfterReturn()
void	testMultiThreadedCompressorPool()
void	testMultiThreadedDecompressorPool()

Methods inherited from class java.lang.Object

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

Field Details

LEASE_COUNT_ERR

private final String LEASE_COUNT_ERR

See Also:

• Constant Field Values

codec

org.apache.hadoop.io.compress.DefaultCodec codec

Constructor Details

TestCodecPool

public TestCodecPool()

Method Details

beforeClass

@BeforeAll
public static void beforeClass()

setup

@BeforeEach
public void setup()

testCompressorPoolCounts

@Test
public void testCompressorPoolCounts()

testCompressorNotReturnSameInstance

@Test
public void testCompressorNotReturnSameInstance()

testDecompressorPoolCounts

@Test
public void testDecompressorPoolCounts()

testMultiThreadedCompressorPool

@Test
public void testMultiThreadedCompressorPool()
                                     throws InterruptedException

Throws:

InterruptedException

testMultiThreadedDecompressorPool

@Test
public void testMultiThreadedDecompressorPool()
                                       throws InterruptedException

Throws:

InterruptedException

testDecompressorNotReturnSameInstance

@Test
public void testDecompressorNotReturnSameInstance()

testDoNotPoolDecompressorNotUseableAfterReturn

@Test
public void testDoNotPoolDecompressorNotUseableAfterReturn()
                                                    throws Exception

Throws:

Exception