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

Class TestGzipByteBuffDecompressor

java.lang.Object

org.apache.hadoop.hbase.io.compress.TestGzipByteBuffDecompressor

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

Field Summary

Fields

Modifier and Type	Field	Description
private static final byte[]	COMPRESSED_PAYLOAD

Constructor Summary

Constructors

Constructor	Description
TestGzipByteBuffDecompressor()

Method Summary

Modifier and Type	Method	Description
private static void	assumeNativeZlibLoaded()	GzipByteBuffDecompressor is backed by Hadoop's native zlib binding, so actually decompressing anything requires that native library to be loaded on this JVM.
private static byte[]	concat(byte[] first, byte[] second)
private static org.apache.hadoop.hbase.nio.ByteBuff	directBuffWith(byte[] data)
private static byte[]	gzip(String text)
private static org.apache.hadoop.hbase.nio.ByteBuff	heapBuffWith(byte[] data)
void	itDecompressDirectFailsOnBadMagicBytes()
void	itDecompressDirectFailsOnCorruptedCrc32()
void	itDecompressDirectFailsOnCorruptedIsize()
void	itDecompressDirectFailsOnTooShortInput()
void	itDecompressDirectFailsOnTruncatedGzipStream()
void	itDecompressDirectFailsWhenOutputBufferTooSmall()
void	itDecompressDirectIsStillUsableAfterAPreviousCallThrows()
void	itDecompressesDirectSuccessfullyOnRepeatedCalls()
void	itDecompressesDirectToDirectSuccessfully()
void	itDecompressesDirectToDirectWithNonZeroBufferPosition()
void	itDecompressesOnlyTheDelimitedMemberFromAMultiMemberPayload()
void	itDecompressThrowsWhenPassedAMultiByteBuff()
void	itReinitControlsByteBuffDecompressionViaConfigFlag()	This is the exact gate HFileBlockDefaultDecodingContext#canDecompressViaByteBuff relies on to decide between ByteBuff decompression and the stream path, driven end-to-end from the GzipHFileDecompressionContext#ALLOW_BYTE_BUFF_DECOMPRESSION_KEY config flag.
void	itReinitFailsOnWrongContextType()
void	itReinitWithNullContextIsNoOp()
void	itReportsCorrectCapabilitiesWithNativeZlib()
void	itReportsCorrectCapabilitiesWithoutNativeZlib()

Methods inherited from class java.lang.Object

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

Field Details

COMPRESSED_PAYLOAD

private static final byte[] COMPRESSED_PAYLOAD

Constructor Details

TestGzipByteBuffDecompressor

public TestGzipByteBuffDecompressor()

Method Details

assumeNativeZlibLoaded

private static void assumeNativeZlibLoaded()

GzipByteBuffDecompressor is backed by Hadoop's native zlib binding, so actually decompressing anything requires that native library to be loaded on this JVM.

itReportsCorrectCapabilitiesWithoutNativeZlib

@Test
public void itReportsCorrectCapabilitiesWithoutNativeZlib()

itReportsCorrectCapabilitiesWithNativeZlib

@Test
public void itReportsCorrectCapabilitiesWithNativeZlib()

directBuffWith

private static org.apache.hadoop.hbase.nio.ByteBuff directBuffWith(byte[] data)

heapBuffWith

private static org.apache.hadoop.hbase.nio.ByteBuff heapBuffWith(byte[] data)

gzip

private static byte[] gzip(String text)

concat

private static byte[] concat(byte[] first,
 byte[] second)

itDecompressesDirectToDirectSuccessfully

@Test
public void itDecompressesDirectToDirectSuccessfully()
                                              throws IOException

Throws:

IOException

itDecompressDirectFailsOnTooShortInput

@Test
public void itDecompressDirectFailsOnTooShortInput()
                                            throws IOException

Throws:

IOException

itDecompressDirectFailsOnBadMagicBytes

@Test
public void itDecompressDirectFailsOnBadMagicBytes()
                                            throws IOException

Throws:

IOException

itDecompressDirectFailsWhenOutputBufferTooSmall

@Test
public void itDecompressDirectFailsWhenOutputBufferTooSmall()
                                                     throws IOException

Throws:

IOException

itDecompressDirectFailsOnCorruptedCrc32

@Test
public void itDecompressDirectFailsOnCorruptedCrc32()
                                             throws IOException

Throws:

IOException

itDecompressDirectFailsOnCorruptedIsize

@Test
public void itDecompressDirectFailsOnCorruptedIsize()
                                             throws IOException

Throws:

IOException

itDecompressesDirectSuccessfullyOnRepeatedCalls

@Test
public void itDecompressesDirectSuccessfullyOnRepeatedCalls()
                                                     throws IOException

Throws:

IOException

itDecompressDirectIsStillUsableAfterAPreviousCallThrows

@Test
public void itDecompressDirectIsStillUsableAfterAPreviousCallThrows()
                                                             throws IOException

Throws:

IOException

itDecompressesDirectToDirectWithNonZeroBufferPosition

@Test
public void itDecompressesDirectToDirectWithNonZeroBufferPosition()
                                                           throws IOException

Throws:

IOException

itDecompressDirectFailsOnTruncatedGzipStream

@Test
public void itDecompressDirectFailsOnTruncatedGzipStream()
                                                  throws IOException

Throws:

IOException

itDecompressesOnlyTheDelimitedMemberFromAMultiMemberPayload

@Test
public void itDecompressesOnlyTheDelimitedMemberFromAMultiMemberPayload()
                                                                 throws IOException

Throws:

IOException

itReinitControlsByteBuffDecompressionViaConfigFlag

@Test
public void itReinitControlsByteBuffDecompressionViaConfigFlag()

This is the exact gate HFileBlockDefaultDecodingContext#canDecompressViaByteBuff relies on to decide between ByteBuff decompression and the stream path, driven end-to-end from the GzipHFileDecompressionContext#ALLOW_BYTE_BUFF_DECOMPRESSION_KEY config flag.

itReinitWithNullContextIsNoOp

@Test
public void itReinitWithNullContextIsNoOp()

itReinitFailsOnWrongContextType

@Test
public void itReinitFailsOnWrongContextType()

itDecompressThrowsWhenPassedAMultiByteBuff

@Test
public void itDecompressThrowsWhenPassedAMultiByteBuff()
                                                throws IOException

Throws:

IOException