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

Class TestCodecPool

java.lang.Object

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

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
static final HBaseClassTestRule	CLASS_RULE
(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

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

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

public static void beforeClass()

setup

public void setup()

testCompressorPoolCounts

public void testCompressorPoolCounts()

testCompressorNotReturnSameInstance

public void testCompressorNotReturnSameInstance()

testDecompressorPoolCounts

public void testDecompressorPoolCounts()

testMultiThreadedCompressorPool

public void testMultiThreadedCompressorPool()
                                     throws InterruptedException

Throws:

InterruptedException

testMultiThreadedDecompressorPool

public void testMultiThreadedDecompressorPool()
                                       throws InterruptedException

Throws:

InterruptedException

testDecompressorNotReturnSameInstance

public void testDecompressorNotReturnSameInstance()

testDoNotPoolDecompressorNotUseableAfterReturn

public void testDoNotPoolDecompressorNotUseableAfterReturn()
                                                    throws Exception

Throws:

Exception