alluxio.underfs.hdfs

Class HdfsUnderFileInputStream

java.lang.Object

java.io.InputStream

java.io.FilterInputStream

alluxio.underfs.SeekableUnderFileInputStream

alluxio.underfs.hdfs.HdfsUnderFileInputStream

All Implemented Interfaces:

Positioned, Seekable, Closeable, AutoCloseable

public class HdfsUnderFileInputStream
extends SeekableUnderFileInputStream

The input stream of HDFS as under filesystem. This input stream supports seeking and can be cached for reuse.

Field Summary

Fields inherited from class java.io.FilterInputStream

in

Method Summary

Modifier and Type	Method and Description
long	getPos()
int	read(byte[] b, int off, int len)
void	seek(long position) Moves the starting read position of the stream to the specified position which is relative to the start of the stream.

Methods inherited from class java.io.FilterInputStream

available, close, mark, markSupported, read, read, reset, skip

Methods inherited from class java.lang.Object

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

Method Detail

seek

public void seek(long position)

Description copied from interface: Seekable

Moves the starting read position of the stream to the specified position which is relative to the start of the stream. Seeking to a position before the current read position is supported.

Parameters:

position - the position to seek to, it must be between 0 and the end of the stream - 1

getPos

public long getPos()
            throws IOException

Returns:

the current position

Throws:

IOException

read

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

Overrides:

read in class FilterInputStream