alluxio.hadoop

Class BaseHdfsFileInputStream

java.lang.Object

java.io.InputStream

alluxio.hadoop.BaseHdfsFileInputStream

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.fs.ByteBufferReadable, org.apache.hadoop.fs.PositionedReadable, org.apache.hadoop.fs.Seekable

Direct Known Subclasses:

HdfsFileInputStream

@NotThreadSafe
public class BaseHdfsFileInputStream
extends InputStream
implements org.apache.hadoop.fs.Seekable, org.apache.hadoop.fs.PositionedReadable, org.apache.hadoop.fs.ByteBufferReadable

An input stream for reading a file from HDFS. This is just a wrapper around FileInStream with additional statistics gathering in a FileSystem.Statistics object.

Field Summary

Fields

Modifier and Type	Field and Description
protected FileInStream	mInputStream

Constructor Summary

Constructors

Constructor and Description
BaseHdfsFileInputStream(FileInStream inputStream, org.apache.hadoop.fs.FileSystem.Statistics stats) Constructs a new stream for reading a file from HDFS.
BaseHdfsFileInputStream(FileSystem fs, AlluxioURI uri, org.apache.hadoop.fs.FileSystem.Statistics stats) Constructs a new stream for reading a file from HDFS.

Method Summary

Modifier and Type	Method and Description
int	available()
void	close()
long	getPos()
int	read()
int	read(byte[] buffer)
int	read(byte[] buffer, int offset, int length)
int	read(ByteBuffer buf)
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	seek(long pos)
boolean	seekToNewSource(long targetPos) This method is not supported in BaseHdfsFileInputStream.
long	skip(long n)

Methods inherited from class java.io.InputStream

mark, markSupported, reset

Methods inherited from class java.lang.Object

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

Field Detail

mInputStream

protected final FileInStream mInputStream

Constructor Detail

BaseHdfsFileInputStream

public BaseHdfsFileInputStream(FileSystem fs,
                               AlluxioURI uri,
                               org.apache.hadoop.fs.FileSystem.Statistics stats)
                        throws IOException

Constructs a new stream for reading a file from HDFS.

Parameters:

fs - the file system

uri - the Alluxio file URI

stats - filesystem statistics

Throws:

IOException

BaseHdfsFileInputStream

public BaseHdfsFileInputStream(FileInStream inputStream,
                               org.apache.hadoop.fs.FileSystem.Statistics stats)

Constructs a new stream for reading a file from HDFS.

Parameters:

inputStream - the input stream

stats - filesystem statistics

Method Detail

available

public int available()
              throws IOException

Overrides:

available in class InputStream

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class InputStream

Throws:

IOException

getPos

public long getPos()
            throws IOException

Specified by:

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

Throws:

IOException

read

public int read()
         throws IOException

Specified by:

read in class InputStream

Throws:

IOException

read

public int read(byte[] buffer)
         throws IOException

Overrides:

read in class InputStream

Throws:

IOException

read

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

Overrides:

read in class InputStream

Throws:

IOException

read

public int read(ByteBuffer buf)
         throws IOException

Specified by:

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

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

seek

public void seek(long pos)
          throws IOException

Specified by:

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

Throws:

IOException

seekToNewSource

public boolean seekToNewSource(long targetPos)
                        throws IOException

This method is not supported in BaseHdfsFileInputStream.

Specified by:

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

Parameters:

targetPos - N/A

Returns:

N/A

Throws:

IOException - always

skip

public long skip(long n)
          throws IOException

Overrides:

skip in class InputStream

Throws:

IOException