Class AvroReaders

java.lang.Object

dev.hardwood.avro.AvroReaders

public final class AvroReaders
extends Object

Factory for creating AvroRowReader instances from a ParquetFileReader.

Mirrors the noun / buildNoun shape of ParquetFileReader: the no-arg rowReader(ParquetFileReader) returns the default reader; buildRowReader(ParquetFileReader) returns a builder for projection / filter / head / tail configuration.

try (ParquetFileReader fileReader = ParquetFileReader.open(inputFile);
     AvroRowReader reader = AvroReaders.rowReader(fileReader)) {
    while (reader.hasNext()) {
        GenericRecord record = reader.next();
        long id = (Long) record.get("id");
    }
}

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	AvroReaders.RowReaderBuilder	Builds an AvroRowReader with optional projection, filter, and head/tail row limit.

Method Summary

Modifier and Type	Method	Description
static AvroReaders.RowReaderBuilder	buildRowReader(ParquetFileReader reader)	Begin configuring an AvroRowReader with optional projection, filter, and head/tail row limit.
static AvroRowReader	rowReader(ParquetFileReader reader)	Create an AvroRowReader that reads all rows and columns.

Methods inherited from class Object

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

Method Details

rowReader

public static AvroRowReader rowReader(ParquetFileReader reader)

Create an AvroRowReader that reads all rows and columns.

buildRowReader

public static AvroReaders.RowReaderBuilder buildRowReader(ParquetFileReader reader)

Begin configuring an AvroRowReader with optional projection, filter, and head/tail row limit.