Class ParquetFileReader.ColumnReaderBuilder

java.lang.Object

dev.hardwood.reader.ParquetFileReader.ColumnReaderBuilder

Enclosing class:

ParquetFileReader

public static final class ParquetFileReader.ColumnReaderBuilder
extends Object

Builds a single-column ColumnReader with an optional filter.

Obtained from ParquetFileReader.buildColumnReader(String) or ParquetFileReader.buildColumnReader(int). Single-file only — multi-file readers must use ParquetFileReader.buildColumnReaders(ColumnProjection) with a projection.

ColumnReader col = file.buildColumnReader("id")
        .filter(FilterPredicate.lt("id", 1000L))
        .build();

Method Summary

Modifier and Type	Method	Description
ColumnReader	build()
ParquetFileReader.ColumnReaderBuilder	filter(FilterPredicate filter)	Apply a column-statistics filter — row groups whose statistics prove no row matches are skipped.
ParquetFileReader.ColumnReaderBuilder	filter(RowGroupPredicate rowGroupFilter)	Apply a row-group selection predicate (e.g. byte-range, for split-aware reading).

Methods inherited from class Object

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

Method Details

filter

public ParquetFileReader.ColumnReaderBuilder filter(FilterPredicate filter)

Apply a column-statistics filter — row groups whose statistics prove no row matches are skipped. Default: no filter.

filter

public ParquetFileReader.ColumnReaderBuilder filter(RowGroupPredicate rowGroupFilter)

Apply a row-group selection predicate (e.g. byte-range, for split-aware reading). Default: read every row group. Combines with filter(FilterPredicate) via intersection: a row group is read if and only if it passes both.

build

public ColumnReader build()