org.apache.paimon.mosaic

Class MosaicReader

java.lang.Object

org.apache.paimon.mosaic.MosaicReader

All Implemented Interfaces:

AutoCloseable

public class MosaicReader
extends Object
implements AutoCloseable

Method Summary

Modifier and Type	Method and Description
void	close()
Map<String,ColumnStatistics>	getRowGroupStatistics(int rgIndex) Returns column statistics for the given row group, keyed by column name.
org.apache.arrow.vector.types.pojo.Schema	getSchema()
int	numRowGroups()
static MosaicReader	open(InputFile inputFile, long fileLength, org.apache.arrow.memory.BufferAllocator allocator)
void	project(String[] columns)
org.apache.arrow.vector.VectorSchemaRoot	readRowGroup(int rgIndex, org.apache.arrow.memory.BufferAllocator allocator)
int	rowGroupNumRows(int rgIndex)

Methods inherited from class java.lang.Object

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

Method Detail

open

public static MosaicReader open(InputFile inputFile,
                                long fileLength,
                                org.apache.arrow.memory.BufferAllocator allocator)

getSchema

public org.apache.arrow.vector.types.pojo.Schema getSchema()

numRowGroups

public int numRowGroups()

project

public void project(String[] columns)

readRowGroup

public org.apache.arrow.vector.VectorSchemaRoot readRowGroup(int rgIndex,
                                                             org.apache.arrow.memory.BufferAllocator allocator)

rowGroupNumRows

public int rowGroupNumRows(int rgIndex)

getRowGroupStatistics

public Map<String,ColumnStatistics> getRowGroupStatistics(int rgIndex)

Returns column statistics for the given row group, keyed by column name.

close

public void close()

Specified by:

close in interface AutoCloseable