Package org.apache.hadoop.hbase.regionserver

Class TestInputStreamBlockDistribution

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestInputStreamBlockDistribution

@Tag("org.apache.hadoop.hbase.testclassification.RegionServerTests") @Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
public class TestInputStreamBlockDistribution
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.conf.Configuration	conf
private org.apache.hadoop.fs.FileSystem	fs
private org.apache.hadoop.fs.Path	testPath

Constructor Summary

Constructors

Constructor	Description
TestInputStreamBlockDistribution()

Method Summary

Modifier and Type	Method	Description
private org.apache.hadoop.hbase.regionserver.StoreFileInfo	getMockedStoreFileInfo(org.apache.hadoop.hbase.HDFSBlocksDistribution distribution, boolean isFileLink)
void	itDerivesLocalityFromFileLinkInputStream()
void	itDerivesLocalityFromHFileInputStream()
void	itFallsBackOnLastKnownValueOnException()
void	itFallsBackOnLastKnownValueWhenUnsupported()
void	setUp()
void	tearDown()
private void	writeSomeData(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, long size, byte v)	Write up to 'size' bytes with value 'v' into a new file called 'path'.

Methods inherited from class java.lang.Object

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

Field Details

conf

private org.apache.hadoop.conf.Configuration conf

fs

private org.apache.hadoop.fs.FileSystem fs

testPath

private org.apache.hadoop.fs.Path testPath

Constructor Details

TestInputStreamBlockDistribution

public TestInputStreamBlockDistribution()

Method Details

setUp

@BeforeEach
public void setUp()
           throws Exception

Throws:

Exception

tearDown

@AfterEach
public void tearDown()
              throws Exception

Throws:

Exception

itDerivesLocalityFromHFileInputStream

@Test
public void itDerivesLocalityFromHFileInputStream()
                                           throws Exception

Throws:

Exception

itDerivesLocalityFromFileLinkInputStream

@Test
public void itDerivesLocalityFromFileLinkInputStream()
                                              throws Exception

Throws:

Exception

itFallsBackOnLastKnownValueWhenUnsupported

@Test
public void itFallsBackOnLastKnownValueWhenUnsupported()

itFallsBackOnLastKnownValueOnException

@Test
public void itFallsBackOnLastKnownValueOnException()
                                            throws IOException

Throws:

IOException

writeSomeData

private void writeSomeData(org.apache.hadoop.fs.FileSystem fs,
 org.apache.hadoop.fs.Path path,
 long size,
 byte v)
                    throws IOException

Write up to 'size' bytes with value 'v' into a new file called 'path'.

Throws:

IOException

getMockedStoreFileInfo

private org.apache.hadoop.hbase.regionserver.StoreFileInfo getMockedStoreFileInfo(org.apache.hadoop.hbase.HDFSBlocksDistribution distribution,
 boolean isFileLink)