Class AvroReaders.RowReaderBuilder

java.lang.Object

dev.hardwood.avro.AvroReaders.RowReaderBuilder

Enclosing class:

AvroReaders

public static final class AvroReaders.RowReaderBuilder
extends Object

Builds an AvroRowReader with optional projection, filter, and head/tail row limit. Mirrors ParquetFileReader.RowReaderBuilder — settings are forwarded to the underlying parquet row reader, then wrapped in an AvroRowReader with the converted schema.

Method Summary

Modifier and Type	Method	Description
AvroRowReader	build()
AvroReaders.RowReaderBuilder	filter(FilterPredicate filter)	Apply a row-group / record-level filter predicate.
AvroReaders.RowReaderBuilder	head(long maxRows)	Limit to the first maxRows rows.
AvroReaders.RowReaderBuilder	projection(ColumnProjection projection)	Restrict reading to the given columns.
AvroReaders.RowReaderBuilder	tail(long tailRows)	Limit to the last tailRows rows.

Methods inherited from class Object

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

Method Details

projection

public AvroReaders.RowReaderBuilder projection(ColumnProjection projection)

Restrict reading to the given columns. Default: all columns.

filter

public AvroReaders.RowReaderBuilder filter(FilterPredicate filter)

Apply a row-group / record-level filter predicate. Default: no filter.

head

public AvroReaders.RowReaderBuilder head(long maxRows)

Limit to the first maxRows rows. Mutually exclusive with tail(long).

tail

public AvroReaders.RowReaderBuilder tail(long tailRows)

Limit to the last tailRows rows. Mutually exclusive with head(long) and filter. Single-file only.

build

public AvroRowReader build()