public class TestHFileBlock
extends java.lang.Object
| Constructor and Description |
|---|
TestHFileBlock(boolean includesMemstoreTS,
boolean includesTag) |
| Modifier and Type | Method and Description |
|---|---|
java.lang.String |
createTestBlockStr(Compression.Algorithm algo,
int correctLength,
boolean useTag) |
byte[] |
createTestV1Block(Compression.Algorithm algo) |
static java.util.Collection<java.lang.Object[]> |
parameters() |
void |
setUp() |
void |
testBlockHeapSize() |
protected void |
testBlockHeapSizeInternals() |
void |
testConcurrentReading() |
protected void |
testConcurrentReadingInternals() |
void |
testDataBlockEncoding()
Test encoding/decoding data blocks.
|
void |
testGzipCompression() |
void |
testNoCompression() |
void |
testPreviousOffset() |
protected void |
testPreviousOffsetInternals() |
void |
testReaderV2() |
protected void |
testReaderV2Internals() |
public TestHFileBlock(boolean includesMemstoreTS,
boolean includesTag)
public static java.util.Collection<java.lang.Object[]> parameters()
public void setUp()
throws java.io.IOException
java.io.IOExceptionpublic byte[] createTestV1Block(Compression.Algorithm algo) throws java.io.IOException
java.io.IOExceptionpublic java.lang.String createTestBlockStr(Compression.Algorithm algo, int correctLength, boolean useTag) throws java.io.IOException
java.io.IOExceptionpublic void testNoCompression()
throws java.io.IOException
java.io.IOExceptionpublic void testGzipCompression()
throws java.io.IOException
java.io.IOExceptionpublic void testReaderV2()
throws java.io.IOException
java.io.IOExceptionprotected void testReaderV2Internals()
throws java.io.IOException
java.io.IOExceptionpublic void testDataBlockEncoding()
throws java.io.IOException
java.io.IOException - a bug or a problem with temporary files.public void testPreviousOffset()
throws java.io.IOException
java.io.IOExceptionprotected void testPreviousOffsetInternals()
throws java.io.IOException
java.io.IOExceptionpublic void testConcurrentReading()
throws java.lang.Exception
java.lang.Exceptionprotected void testConcurrentReadingInternals()
throws java.io.IOException,
java.lang.InterruptedException,
java.util.concurrent.ExecutionException
java.io.IOExceptionjava.lang.InterruptedExceptionjava.util.concurrent.ExecutionExceptionpublic void testBlockHeapSize()
protected void testBlockHeapSizeInternals()