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 which can read from a CLI style file URI, ex."s3://bucket/key".

Field Summary

Fields

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

Method Summary

Modifier and Type	Method	Description
static ParquetFileReader	create(@NotNull URI parquetFileURI, @NotNull SeekableChannelsProvider channelsProvider)	Make a ParquetFileReader for the supplied URI.
SeekableChannelsProvider	getChannelsProvider()
org.apache.parquet.hadoop.metadata.ParquetMetadata	getMetadata()
RowGroupReader	getRowGroup(int groupNumber, String version)	Create a RowGroupReader object for provided row group number
org.apache.parquet.schema.MessageType	getSchema()

Methods inherited from class java.lang.Object

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

Field Details

FILE_URI_SCHEME

public static final String FILE_URI_SCHEME

See Also:

• Constant Field Values

fileMetaData

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

Method Details

create

public static ParquetFileReader create(@NotNull
 @NotNull URI parquetFileURI,
 @NotNull
 @NotNull SeekableChannelsProvider channelsProvider)

Make a ParquetFileReader for the supplied URI. Wraps IOException as UncheckedIOException.

Parameters:

parquetFileURI - The URI for the parquet file or the parquet metadata file

channelsProvider - The SeekableChannelsProvider to use for reading the file

Returns:

The new ParquetFileReader

getChannelsProvider

public SeekableChannelsProvider getChannelsProvider()

Returns:

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

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.

getMetadata

public org.apache.parquet.hadoop.metadata.ParquetMetadata getMetadata()

getSchema

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