org.apache.iceberg.parquet

Class ParquetDictionaryRowGroupFilter

java.lang.Object

org.apache.iceberg.parquet.ParquetDictionaryRowGroupFilter

public class ParquetDictionaryRowGroupFilter
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
ParquetDictionaryRowGroupFilter(Schema schema, Expression unbound)
ParquetDictionaryRowGroupFilter(Schema schema, Expression unbound, boolean caseSensitive)

Method Summary

Modifier and Type	Method and Description
boolean	shouldRead(org.apache.parquet.schema.MessageType fileSchema, org.apache.parquet.hadoop.metadata.BlockMetaData rowGroup, org.apache.parquet.column.page.DictionaryPageReadStore dictionaries) Test whether the dictionaries for a row group may contain records that match the expression.

Methods inherited from class java.lang.Object

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

Constructor Detail

ParquetDictionaryRowGroupFilter

public ParquetDictionaryRowGroupFilter(Schema schema,
                                       Expression unbound)

ParquetDictionaryRowGroupFilter

public ParquetDictionaryRowGroupFilter(Schema schema,
                                       Expression unbound,
                                       boolean caseSensitive)

Method Detail

shouldRead

public boolean shouldRead(org.apache.parquet.schema.MessageType fileSchema,
                          org.apache.parquet.hadoop.metadata.BlockMetaData rowGroup,
                          org.apache.parquet.column.page.DictionaryPageReadStore dictionaries)

Test whether the dictionaries for a row group may contain records that match the expression.

Parameters:

fileSchema - schema for the Parquet file

dictionaries - a dictionary page read store

Returns:

false if the file cannot contain rows that match the expression, true otherwise.