Package org.apache.hadoop.hbase.io.hfile

Class TestBlockIOUtils

java.lang.Object

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

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestBlockIOUtils.MyFSDataInputStream

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.apache.hadoop.hbase.io.compress.Compression.Algorithm	COMPRESSION_ALGO
private String	methodName
private static final int	NUM_TEST_BLOCKS
private static io.opentelemetry.sdk.testing.junit5.OpenTelemetryExtension	OTEL_EXT
private static final HBaseTestingUtil	TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
TestBlockIOUtils()

Method Summary

Modifier and Type	Method	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	setUp(org.junit.jupiter.api.TestInfo testInfo)
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 Details

methodName

private String methodName

OTEL_EXT

@RegisterExtension
private static io.opentelemetry.sdk.testing.junit5.OpenTelemetryExtension OTEL_EXT

TEST_UTIL

private static final HBaseTestingUtil 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 Details

TestBlockIOUtils

public TestBlockIOUtils()

Method Details

setUp

@BeforeEach
public void setUp(org.junit.jupiter.api.TestInfo testInfo)

testIsByteBufferReadable

@Test
public void testIsByteBufferReadable()
                              throws IOException

Throws:

IOException

testReadFully

@Test
public void testReadFully()
                   throws IOException

Throws:

IOException

testPreadWithReadFullBytes

@Test
public void testPreadWithReadFullBytes()
                                throws IOException

Throws:

IOException

testPreadWithoutReadFullBytes

@Test
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

@Test
public void testReadWithExtra()
                       throws IOException

Throws:

IOException

testPositionalReadNoExtra

@Test
public void testPositionalReadNoExtra()
                               throws IOException

Throws:

IOException

testPositionalReadShortReadOfNecessaryBytes

@Test
public void testPositionalReadShortReadOfNecessaryBytes()
                                                 throws IOException

Throws:

IOException

testPositionalReadExtraSucceeded

@Test
public void testPositionalReadExtraSucceeded()
                                      throws IOException

Throws:

IOException

testPositionalReadExtraFailed

@Test
public void testPositionalReadExtraFailed()
                                   throws IOException

Throws:

IOException

testPositionalReadShortReadCompletesNecessaryAndExtraBytes

@Test
public void testPositionalReadShortReadCompletesNecessaryAndExtraBytes()
                                                                throws IOException

Throws:

IOException

testPositionalReadPrematureEOF

@Test
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

@Test
public void testByteBufferPositionedReadable()
                                      throws IOException

Throws:

IOException

testByteBufferPositionedReadableEOF

@Test
public void testByteBufferPositionedReadableEOF()
                                         throws IOException

Throws:

IOException