alluxio.hadoop

Class HdfsFileInputStream

java.lang.Object

java.io.InputStream

alluxio.hadoop.BaseHdfsFileInputStream

alluxio.hadoop.HdfsFileInputStream

All Implemented Interfaces:

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

public class HdfsFileInputStream
extends BaseHdfsFileInputStream

HdfsFileInputStream implement for hadoop 1 and hadoop 2.

Field Summary

Fields inherited from class alluxio.hadoop.BaseHdfsFileInputStream

mInputStream

Constructor Summary

Constructors

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

Method Summary

Methods inherited from class alluxio.hadoop.BaseHdfsFileInputStream

available, close, getPos, read, read, read, read, read, readFully, readFully, seek, seekToNewSource, skip

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

Constructor Detail

HdfsFileInputStream

public HdfsFileInputStream(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

HdfsFileInputStream

public HdfsFileInputStream(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