org.apache.paimon.io

Class CompressedPageFileInput

java.lang.Object

org.apache.paimon.io.CompressedPageFileInput

All Implemented Interfaces:

Closeable, AutoCloseable, PageFileInput

public class CompressedPageFileInput
extends Object
implements PageFileInput

A class to wrap compressed RandomAccessFile.

Constructor Summary

Constructors

Constructor and Description
CompressedPageFileInput(RandomAccessFile file, int pageSize, BlockCompressionFactory compressionFactory, long uncompressedBytes, long[] pagePositions)

Method Summary

Modifier and Type	Method and Description
void	close()
RandomAccessFile	file()
int	pageSize()
byte[]	readPage(int pageIndex)
byte[]	readPosition(long position, int length)
long	uncompressBytes()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.paimon.io.PageFileInput

create

Constructor Detail

CompressedPageFileInput

public CompressedPageFileInput(RandomAccessFile file,
                               int pageSize,
                               BlockCompressionFactory compressionFactory,
                               long uncompressedBytes,
                               long[] pagePositions)

Method Detail

file

public RandomAccessFile file()

Specified by:

file in interface PageFileInput

uncompressBytes

public long uncompressBytes()

Specified by:

uncompressBytes in interface PageFileInput

pageSize

public int pageSize()

Specified by:

pageSize in interface PageFileInput

readPage

public byte[] readPage(int pageIndex)
                throws IOException

Specified by:

readPage in interface PageFileInput

Throws:

IOException

readPosition

public byte[] readPosition(long position,
                           int length)
                    throws IOException

Specified by:

readPosition in interface PageFileInput

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException