Package io.deephaven.parquet.base

Class ParquetFileReader

java.lang.Object

io.deephaven.parquet.base.ParquetFileReader

public class ParquetFileReader
extends Object

Top level accessor for a parquet file

Field Summary

Fields

Modifier and Type	Field	Description
final org.apache.parquet.format.FileMetaData	fileMetaData

Constructor Summary

Constructors

Constructor	Description
ParquetFileReader(String filePath, SeekableChannelsProvider channelsProvider)

Method Summary

Modifier and Type	Method	Description
SeekableChannelsProvider	getChannelsProvider()
Set<String>	getColumnsWithDictionaryUsedOnEveryDataPage()	Get the name of all columns that we can know for certain (a) have a dictionary, and (b) use the dictionary on all data pages.
RowGroupReader	getRowGroup(int groupNumber, String version)	Create a RowGroupReader object for provided row group number
org.apache.parquet.schema.MessageType	getSchema()
int	rowGroupCount()

Methods inherited from class java.lang.Object

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

Field Details

fileMetaData

public final org.apache.parquet.format.FileMetaData fileMetaData

Constructor Details

ParquetFileReader

public ParquetFileReader(String filePath,
 SeekableChannelsProvider channelsProvider)
                  throws IOException

Throws:

IOException

Method Details

getChannelsProvider

public SeekableChannelsProvider getChannelsProvider()

Returns:

The SeekableChannelsProvider used for this reader, appropriate to use for related file access

getColumnsWithDictionaryUsedOnEveryDataPage

public Set<String> getColumnsWithDictionaryUsedOnEveryDataPage()

Get the name of all columns that we can know for certain (a) have a dictionary, and (b) use the dictionary on all data pages.

Returns:

A set of parquet column names that satisfies the required condition.

getRowGroup

public RowGroupReader getRowGroup(int groupNumber,
 String version)

Create a RowGroupReader object for provided row group number

Parameters:

version - The "version" string from deephaven specific parquet metadata, or null if it's not present.

getSchema

public org.apache.parquet.schema.MessageType getSchema()

rowGroupCount

public int rowGroupCount()