org.apache.hadoop.hbase.io

Class TestFileLink

java.lang.Object

org.apache.hadoop.hbase.io.TestFileLink

public class TestFileLink
extends Object

Test that FileLink switches between alternate locations when the current location moves or gets deleted.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	TestFileLink.MyDistributedFileSystem

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE

Constructor Summary

Constructors

Constructor and Description
TestFileLink()

Method Summary

Modifier and Type	Method and Description
private static void	dataVerify(byte[] data, int n, byte v) Verify that all bytes in 'data' have 'v' as value.
private static void	skipBuffer(org.apache.hadoop.fs.FSDataInputStream in, byte v)
void	testEquals()
void	testGetUnderlyingFSDataInputStream() Test that the returned link from FileLink.open(FileSystem) can be unwrapped to a HdfsDataInputStream by FileLink.getUnderlyingFileLinkInputStream(FSDataInputStream)
void	testHashCode()
void	testHDFSLinkReadDuringDelete() Test that link is still readable even when the current file gets deleted.
void	testHDFSLinkReadDuringRename() Test, on HDFS, that the FileLink is still readable even when the current file gets renamed.
private void	testLinkReadDuringRename(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path rootDir) Test that link is still readable even when the current file gets renamed.
void	testLinkReadWithMissingFile()
void	testLocalLinkReadDuringRename() Test, on a local filesystem, that the FileLink is still readable even when the current file gets renamed.
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 Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

Constructor Detail

TestFileLink

public TestFileLink()

Method Detail

testEquals

public void testEquals()

testHashCode

public void testHashCode()

testGetUnderlyingFSDataInputStream

public void testGetUnderlyingFSDataInputStream()
                                        throws Exception

Test that the returned link from FileLink.open(FileSystem) can be unwrapped to a HdfsDataInputStream by FileLink.getUnderlyingFileLinkInputStream(FSDataInputStream)

Throws:

Exception

testHDFSLinkReadDuringRename

public void testHDFSLinkReadDuringRename()
                                  throws Exception

Test, on HDFS, that the FileLink is still readable even when the current file gets renamed.

Throws:

Exception

testLinkReadWithMissingFile

public void testLinkReadWithMissingFile()
                                 throws Exception

Throws:

Exception

testLocalLinkReadDuringRename

public void testLocalLinkReadDuringRename()
                                   throws IOException

Test, on a local filesystem, that the FileLink is still readable even when the current file gets renamed.

Throws:

IOException

testLinkReadDuringRename

private void testLinkReadDuringRename(org.apache.hadoop.fs.FileSystem fs,
                                      org.apache.hadoop.fs.Path rootDir)
                               throws IOException

Test that link is still readable even when the current file gets renamed.

Throws:

IOException

testHDFSLinkReadDuringDelete

public void testHDFSLinkReadDuringDelete()
                                  throws Exception

Test that link is still readable even when the current file gets deleted. NOTE: This test is valid only on HDFS. When a file is deleted from a local file-system, it is simply 'unlinked'. The inode, which contains the file's data, is not deleted until all processes have finished with it. In HDFS when the request exceed the cached block locations, a query to the namenode is performed, using the filename, and the deleted file doesn't exists anymore (FileNotFoundException).

Throws:

Exception

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

dataVerify

private static void dataVerify(byte[] data,
                               int n,
                               byte v)

Verify that all bytes in 'data' have 'v' as value.

skipBuffer

private static void skipBuffer(org.apache.hadoop.fs.FSDataInputStream in,
                               byte v)
                        throws IOException

Throws:

IOException