org.apache.hadoop.hbase.io.hfile

Class TestBlockIOUtils

java.lang.Object

org.apache.hadoop.hbase.io.hfile.TestBlockIOUtils

public class TestBlockIOUtils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestBlockIOUtils.MyFSDataInputStream

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static org.apache.hadoop.hbase.io.compress.Compression.Algorithm	COMPRESSION_ALGO
org.junit.rules.ExpectedException	exception
private static int	NUM_TEST_BLOCKS
io.opentelemetry.sdk.testing.junit4.OpenTelemetryRule	otelRule
private static HBaseTestingUtility	TEST_UTIL
org.junit.rules.TestName	testName

Constructor Summary

Constructors

Constructor and Description
TestBlockIOUtils()

Method Summary

Modifier and Type	Method and Description
private void	deleteFile(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path)
private boolean	isByteBufferPositionedReadable() Determine if ByteBufferPositionedReadable API is available .
private void	readDataBlocksAndVerify(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, org.apache.hadoop.hbase.io.compress.Compression.Algorithm compressAlgo, long totalDataBlockBytes)
void	testByteBufferPositionedReadable()
void	testByteBufferPositionedReadableEOF()
void	testIsByteBufferReadable()
void	testPositionalReadExtraFailed()
void	testPositionalReadExtraSucceeded()
void	testPositionalReadNoExtra()
void	testPositionalReadPrematureEOF()
void	testPositionalReadShortReadCompletesNecessaryAndExtraBytes()
void	testPositionalReadShortReadOfNecessaryBytes()
private void	testPreadReadFullBytesInternal(boolean readAllBytes, long randomSeed)
void	testPreadWithoutReadFullBytes()
void	testPreadWithReadFullBytes()
void	testReadFully()
void	testReadWithExtra()
private long	writeBlocks(org.apache.hadoop.conf.Configuration conf, Random rand, org.apache.hadoop.hbase.io.compress.Compression.Algorithm compressAlgo, org.apache.hadoop.fs.Path path)

Methods inherited from class java.lang.Object

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

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

testName

public org.junit.rules.TestName testName

exception

public org.junit.rules.ExpectedException exception

otelRule

public io.opentelemetry.sdk.testing.junit4.OpenTelemetryRule otelRule

TEST_UTIL

private static final HBaseTestingUtility TEST_UTIL

NUM_TEST_BLOCKS

private static final int NUM_TEST_BLOCKS

See Also:

Constant Field Values

COMPRESSION_ALGO

private static final org.apache.hadoop.hbase.io.compress.Compression.Algorithm COMPRESSION_ALGO

Constructor Detail

TestBlockIOUtils

public TestBlockIOUtils()

Method Detail

testIsByteBufferReadable

public void testIsByteBufferReadable()
                              throws IOException

Throws:

IOException

testReadFully

public void testReadFully()
                   throws IOException

Throws:

IOException

testPreadWithReadFullBytes

public void testPreadWithReadFullBytes()
                                throws IOException

Throws:

IOException

testPreadWithoutReadFullBytes

public void testPreadWithoutReadFullBytes()
                                   throws IOException

Throws:

IOException

testPreadReadFullBytesInternal

private void testPreadReadFullBytesInternal(boolean readAllBytes,
                                            long randomSeed)
                                     throws IOException

Throws:

IOException

writeBlocks

private long writeBlocks(org.apache.hadoop.conf.Configuration conf,
                         Random rand,
                         org.apache.hadoop.hbase.io.compress.Compression.Algorithm compressAlgo,
                         org.apache.hadoop.fs.Path path)
                  throws IOException

Throws:

IOException

readDataBlocksAndVerify

private void readDataBlocksAndVerify(org.apache.hadoop.fs.FileSystem fs,
                                     org.apache.hadoop.fs.Path path,
                                     org.apache.hadoop.hbase.io.compress.Compression.Algorithm compressAlgo,
                                     long totalDataBlockBytes)
                              throws IOException

Throws:

IOException

deleteFile

private void deleteFile(org.apache.hadoop.fs.FileSystem fs,
                        org.apache.hadoop.fs.Path path)
                 throws IOException

Throws:

IOException

testReadWithExtra

public void testReadWithExtra()
                       throws IOException

Throws:

IOException

testPositionalReadNoExtra

public void testPositionalReadNoExtra()
                               throws IOException

Throws:

IOException

testPositionalReadShortReadOfNecessaryBytes

public void testPositionalReadShortReadOfNecessaryBytes()
                                                 throws IOException

Throws:

IOException

testPositionalReadExtraSucceeded

public void testPositionalReadExtraSucceeded()
                                      throws IOException

Throws:

IOException

testPositionalReadExtraFailed

public void testPositionalReadExtraFailed()
                                   throws IOException

Throws:

IOException

testPositionalReadShortReadCompletesNecessaryAndExtraBytes

public void testPositionalReadShortReadCompletesNecessaryAndExtraBytes()
                                                                throws IOException

Throws:

IOException

testPositionalReadPrematureEOF

public void testPositionalReadPrematureEOF()
                                    throws IOException

Throws:

IOException

isByteBufferPositionedReadable

private boolean isByteBufferPositionedReadable()

Determine if ByteBufferPositionedReadable API is available .

Returns:

true if FSDataInputStream implements ByteBufferPositionedReadable API.

testByteBufferPositionedReadable

public void testByteBufferPositionedReadable()
                                      throws IOException

Throws:

IOException

testByteBufferPositionedReadableEOF

public void testByteBufferPositionedReadableEOF()
                                         throws IOException

Throws:

IOException