edu.iu.dsc.tws.api.data

Class FSDataInputStream

java.lang.Object

java.io.InputStream

edu.iu.dsc.tws.api.data.FSDataInputStream

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

Direct Known Subclasses:

HadoopDataInputStream, LocalDataInputStream

public abstract class FSDataInputStream
extends java.io.InputStream

Interface for a data input stream to a file on a FileSystem.

This extends the InputStream with methods for accessing the stream's current position and seeking to a desired position.

Constructor Summary

Constructors

Constructor and Description
FSDataInputStream()

Method Summary

Modifier and Type	Method and Description
abstract long	getPos() Gets the current position in the input stream.
abstract java.io.Reader	getReader()
abstract void	seek(long desired) Seek to the given offset from the start of the file.

Methods inherited from class java.io.InputStream

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

Methods inherited from class java.lang.Object

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

Constructor Detail

FSDataInputStream

public FSDataInputStream()

Method Detail

seek

public abstract void seek(long desired)
                   throws java.io.IOException

Seek to the given offset from the start of the file. The next read() will be from that location. Can't seek past the end of the file.

Parameters:

desired - the desired offset

Throws:

java.io.IOException - Thrown if an error occurred while seeking inside the input stream.

getPos

public abstract long getPos()
                     throws java.io.IOException

Gets the current position in the input stream.

Returns:

current position in the input stream

Throws:

java.io.IOException - Thrown if an I/O error occurred in the underlying stream implementation while accessing the stream's position.

getReader

public abstract java.io.Reader getReader()
                                  throws java.io.FileNotFoundException

Throws:

java.io.FileNotFoundException