Package com.here.platform.data.client.flink.impl.decoders.parquet

Class ByteArrayInputFile.ByteArraySeekableInputStream

java.lang.Object

java.io.InputStream

org.apache.parquet.io.SeekableInputStream

org.apache.parquet.io.DelegatingSeekableInputStream

com.here.platform.data.client.flink.impl.decoders.parquet.ByteArrayInputFile.ByteArraySeekableInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

ByteArrayInputFile

public class ByteArrayInputFile.ByteArraySeekableInputStream
extends org.apache.parquet.io.DelegatingSeekableInputStream

Constructor Summary

Constructors

Constructor	Description
ByteArraySeekableInputStream(ByteArrayInputFile.ByteArrayInputStreamWithPos in)

Method Summary

Modifier and Type	Method	Description
long	getPos()
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 org.apache.parquet.io.SeekableInputStream

readVectored, readVectoredAvailable

Methods inherited from class java.io.InputStream

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

Methods inherited from class java.lang.Object

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

Constructor Details

ByteArraySeekableInputStream

public ByteArraySeekableInputStream(ByteArrayInputFile.ByteArrayInputStreamWithPos in)

Method Details

getPos

public long getPos()

Specified by:

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

seek

public void seek(long newPos)

Specified by:

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