org.apache.paimon.format.parquet

Class ParquetInputStream

java.lang.Object

java.io.InputStream

org.apache.parquet.io.SeekableInputStream

org.apache.parquet.io.DelegatingSeekableInputStream

org.apache.paimon.format.parquet.ParquetInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

public class ParquetInputStream
extends org.apache.parquet.io.DelegatingSeekableInputStream

A SeekableInputStream for paimon.

Constructor Summary

Constructors

Constructor and Description
ParquetInputStream(SeekableInputStream in)

Method Summary

Modifier and Type	Method and Description
long	getPos()
SeekableInputStream	in()
void	seek(long newPos)

Methods inherited from class org.apache.parquet.io.DelegatingSeekableInputStream

close, getStream, read, read, read, readFully, readFully, readFully

Methods inherited from class java.io.InputStream

available, mark, markSupported, read, reset, skip

Methods inherited from class java.lang.Object

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

Constructor Detail

ParquetInputStream

public ParquetInputStream(SeekableInputStream in)

Method Detail

in

public SeekableInputStream in()

getPos

public long getPos()
            throws IOException

Specified by:

getPos in class org.apache.parquet.io.DelegatingSeekableInputStream

Throws:

IOException

seek

public void seek(long newPos)
          throws IOException

Specified by:

seek in class org.apache.parquet.io.DelegatingSeekableInputStream

Throws:

IOException