alluxio.underfs.hdfs

Class HdfsPositionedUnderFileInputStream

java.lang.Object

java.io.InputStream

java.io.FilterInputStream

alluxio.underfs.SeekableUnderFileInputStream

alluxio.underfs.hdfs.HdfsPositionedUnderFileInputStream

All Implemented Interfaces:

Positioned, Seekable, Closeable, AutoCloseable

public class HdfsPositionedUnderFileInputStream
extends SeekableUnderFileInputStream

The input stream of HDFS as under filesystem. This input stream has two mode of operations. Under sequential mode, it uses the read api and can take advantage of underlying stream's buffering. Under random read mode, it uses the positionedRead FSDataInputStream API. This stream can be cached for reuse.

Field Summary

Fields inherited from class java.io.FilterInputStream

in

Method Summary

Modifier and Type	Method and Description
int	available()
long	getPos()
boolean	markSupported()
int	read()
int	read(byte[] b)
int	read(byte[] buffer, int offset, int length) If there has been a number of sequential reads in a row, we move to regular buffered reads.
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.
long	skip(long n)

Methods inherited from class java.io.FilterInputStream

close, mark, reset

Methods inherited from class java.lang.Object

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

Method Detail

available

public int available()
              throws IOException

Overrides:

available in class FilterInputStream

Throws:

IOException

getPos

public long getPos()
            throws IOException

Returns:

the current position

Throws:

IOException

read

public int read()
         throws IOException

Overrides:

read in class FilterInputStream

Throws:

IOException

read

public int read(byte[] b)
         throws IOException

Overrides:

read in class FilterInputStream

Throws:

IOException

read

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

If there has been a number of sequential reads in a row, we move to regular buffered reads.

Overrides:

read in class FilterInputStream

Throws:

IOException

seek

public void seek(long position)
          throws IOException

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

Throws:

IOException

skip

public long skip(long n)
          throws IOException

Overrides:

skip in class FilterInputStream

Throws:

IOException

markSupported

public boolean markSupported()

Overrides:

markSupported in class FilterInputStream