org.apache.flink.core.fs

Class FSDataInputStream

java.lang.Object

java.io.InputStream

org.apache.flink.core.fs.FSDataInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

FSDataInputStreamWrapper, HadoopDataInputStream, InputStreamFSInputWrapper, LocalDataInputStream

@Public
public abstract class FSDataInputStream
extends 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 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 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 stream.

Parameters:

desired - the desired offset

Throws:

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

getPos

public abstract long getPos()
                     throws IOException

Gets the current position in the input stream.

Returns:

current position in the input stream

Throws:

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