Package org.apache.iceberg.io

Class SeekableInputStream

java.lang.Object

java.io.InputStream

org.apache.iceberg.io.SeekableInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

AesGcmInputStream, ByteBufferInputStream

public abstract class SeekableInputStream
extends InputStream

SeekableInputStream is an interface with the methods needed to read data from a file or Hadoop data stream.

This class is based on Parquet's SeekableInputStream.

Constructor Summary

Constructors

Constructor	Description
SeekableInputStream()

Method Summary

Modifier and Type	Method	Description
abstract long	getPos()	Return the current position in the InputStream.
abstract void	seek(long newPos)	Seek to a new position in the InputStream.

Methods inherited from class java.io.InputStream

available, close, mark, markSupported, nullInputStream, read, read, read, readAllBytes, readNBytes, readNBytes, reset, skip, skipNBytes, transferTo

Methods inherited from class java.lang.Object

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

Constructor Details

SeekableInputStream

public SeekableInputStream()

Method Details

getPos

public abstract long getPos()
                     throws IOException

Return the current position in the InputStream.

Returns:

current position in bytes from the start of the stream

Throws:

IOException - If the underlying stream throws IOException

seek

public abstract void seek(long newPos)
                   throws IOException

Seek to a new position in the InputStream.

Parameters:

newPos - the new position to seek to

Throws:

IOException - If the underlying stream throws IOException