Package org.apache.hadoop.hbase.io

Class FileLink.FileLinkInputStream

java.lang.Object

java.io.InputStream

org.apache.hadoop.hbase.io.FileLink.FileLinkInputStream

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.fs.CanSetDropBehind, org.apache.hadoop.fs.CanSetReadahead, org.apache.hadoop.fs.CanUnbuffer, org.apache.hadoop.fs.PositionedReadable, org.apache.hadoop.fs.Seekable

Enclosing class:

FileLink

protected static class FileLink.FileLinkInputStream
extends InputStream
implements org.apache.hadoop.fs.Seekable, org.apache.hadoop.fs.PositionedReadable, org.apache.hadoop.fs.CanSetDropBehind, org.apache.hadoop.fs.CanSetReadahead, org.apache.hadoop.fs.CanUnbuffer

FileLink InputStream that handles the switch between the original path and the alternative locations, when the file is moved.

Field Summary

Fields

Modifier and Type	Field	Description
private final int	bufferSize
private org.apache.hadoop.fs.Path	currentPath
private final FileLink	fileLink
private final org.apache.hadoop.fs.FileSystem	fs
private org.apache.hadoop.fs.FSDataInputStream	in
private long	pos

Constructor Summary

Constructors

Constructor	Description
FileLinkInputStream(org.apache.hadoop.fs.FileSystem fs, FileLink fileLink)
FileLinkInputStream(org.apache.hadoop.fs.FileSystem fs, FileLink fileLink, int bufferSize)

Method Summary

Modifier and Type	Method	Description
int	available()
void	close()
org.apache.hadoop.fs.Path	getCurrentPath()
long	getPos()
private org.apache.hadoop.fs.FSDataInputStream	getUnderlyingInputStream()
void	mark(int readlimit)
boolean	markSupported()
int	read()
int	read(byte[] b)
int	read(byte[] b, int off, int len)
int	read(long position, byte[] buffer, int offset, int length)
void	readFully(long position, byte[] buffer)
void	readFully(long position, byte[] buffer, int offset, int length)
void	reset()
void	seek(long pos)
boolean	seekToNewSource(long targetPos)
void	setDropBehind(Boolean dropCache)
void	setReadahead(Long readahead)
long	skip(long n)
private org.apache.hadoop.fs.FSDataInputStream	tryOpen()	Try to open the file from one of the available locations.
void	unbuffer()

Methods inherited from class java.lang.Object

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

Field Details

in

private org.apache.hadoop.fs.FSDataInputStream in

currentPath

private org.apache.hadoop.fs.Path currentPath

pos

private long pos

fileLink

private final FileLink fileLink

bufferSize

private final int bufferSize

fs

private final org.apache.hadoop.fs.FileSystem fs

Constructor Details

FileLinkInputStream

public FileLinkInputStream(org.apache.hadoop.fs.FileSystem fs,
 FileLink fileLink)
                    throws IOException

Throws:

IOException

FileLinkInputStream

public FileLinkInputStream(org.apache.hadoop.fs.FileSystem fs,
 FileLink fileLink,
 int bufferSize)
                    throws IOException

Throws:

IOException

Method Details

getUnderlyingInputStream

private org.apache.hadoop.fs.FSDataInputStream getUnderlyingInputStream()

read

public int read()
         throws IOException

Specified by:

read in class InputStream

Throws:

IOException

read

public int read(byte[] b)
         throws IOException

Overrides:

read in class InputStream

Throws:

IOException

read

public int read(byte[] b,
 int off,
 int len)
         throws IOException

Overrides:

read in class InputStream

Throws:

IOException

read

public int read(long position,
 byte[] buffer,
 int offset,
 int length)
         throws IOException

Specified by:

read in interface org.apache.hadoop.fs.PositionedReadable

Throws:

IOException

readFully

public void readFully(long position,
 byte[] buffer)
               throws IOException

Specified by:

readFully in interface org.apache.hadoop.fs.PositionedReadable

Throws:

IOException

readFully

public void readFully(long position,
 byte[] buffer,
 int offset,
 int length)
               throws IOException

Specified by:

readFully in interface org.apache.hadoop.fs.PositionedReadable

Throws:

IOException

skip

public long skip(long n)
          throws IOException

Overrides:

skip in class InputStream

Throws:

IOException

available

public int available()
              throws IOException

Overrides:

available in class InputStream

Throws:

IOException

seek

public void seek(long pos)
          throws IOException

Specified by:

seek in interface org.apache.hadoop.fs.Seekable

Throws:

IOException

getPos

public long getPos()
            throws IOException

Specified by:

getPos in interface org.apache.hadoop.fs.Seekable

Throws:

IOException

seekToNewSource

public boolean seekToNewSource(long targetPos)
                        throws IOException

Specified by:

seekToNewSource in interface org.apache.hadoop.fs.Seekable

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class InputStream

Throws:

IOException

mark

public void mark(int readlimit)

Overrides:

mark in class InputStream

reset

public void reset()
           throws IOException

Overrides:

reset in class InputStream

Throws:

IOException

markSupported

public boolean markSupported()

Overrides:

markSupported in class InputStream

unbuffer

public void unbuffer()

Specified by:

unbuffer in interface org.apache.hadoop.fs.CanUnbuffer

tryOpen

private org.apache.hadoop.fs.FSDataInputStream tryOpen()
                                                throws IOException

Try to open the file from one of the available locations.

Returns:

FSDataInputStream stream of the opened file link

Throws:

IOException - on unexpected error, or file not found.

setReadahead

public void setReadahead(Long readahead)
                  throws IOException,
UnsupportedOperationException

Specified by:

setReadahead in interface org.apache.hadoop.fs.CanSetReadahead

Throws:

IOException

UnsupportedOperationException

setDropBehind

public void setDropBehind(Boolean dropCache)
                   throws IOException,
UnsupportedOperationException

Specified by:

setDropBehind in interface org.apache.hadoop.fs.CanSetDropBehind

Throws:

IOException

UnsupportedOperationException

getCurrentPath

public org.apache.hadoop.fs.Path getCurrentPath()