Package org.apache.iceberg.avro

Class Avro.ReadBuilder

java.lang.Object

org.apache.iceberg.avro.Avro.ReadBuilder

All Implemented Interfaces:

InternalData.ReadBuilder

Enclosing class:

Avro

public static class Avro.ReadBuilder
extends Object
implements InternalData.ReadBuilder

Method Summary

Modifier and Type	Method	Description
<D> AvroIterable<D>	build()	Build the configured reader.
Avro.ReadBuilder	classLoader(ClassLoader classLoader)
Avro.ReadBuilder	createReaderFunc(BiFunction<Schema,org.apache.avro.Schema,org.apache.avro.io.DatumReader<?>> readerFunction)
Avro.ReadBuilder	createReaderFunc(Function<org.apache.avro.Schema,org.apache.avro.io.DatumReader<?>> readerFunction)
Avro.ReadBuilder	createResolvingReader(Function<Schema,org.apache.avro.io.DatumReader<?>> readerFunction)
Avro.ReadBuilder	project(Schema projectedSchema)	Set the projection schema.
Avro.ReadBuilder	rename(String fullName, String newName)
Avro.ReadBuilder	reuseContainers()	Reuse container classes, like structs, lists, and maps.
Avro.ReadBuilder	reuseContainers(boolean shouldReuse)
InternalData.ReadBuilder	setCustomType(int fieldId, Class<? extends StructLike> structClass)	Set a custom class for in-memory objects at the given field ID.
InternalData.ReadBuilder	setRootType(Class<? extends StructLike> rootClass)	Set a custom class for in-memory objects at the schema root.
Avro.ReadBuilder	split(long newStart, long newLength)	Restricts the read to the given range: [start, end = start + length).
Avro.ReadBuilder	withNameMapping(NameMapping newNameMapping)

Methods inherited from class java.lang.Object

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

Method Details

createResolvingReader

public Avro.ReadBuilder createResolvingReader(Function<Schema,org.apache.avro.io.DatumReader<?>> readerFunction)

createReaderFunc

public Avro.ReadBuilder createReaderFunc(Function<org.apache.avro.Schema,org.apache.avro.io.DatumReader<?>> readerFunction)

createReaderFunc

public Avro.ReadBuilder createReaderFunc(BiFunction<Schema,org.apache.avro.Schema,org.apache.avro.io.DatumReader<?>> readerFunction)

split

public Avro.ReadBuilder split(long newStart,
 long newLength)

Restricts the read to the given range: [start, end = start + length).

Specified by:

split in interface InternalData.ReadBuilder

Parameters:

newStart - the start position for this read

newLength - the length of the range this read should scan

Returns:

this builder for method chaining

project

public Avro.ReadBuilder project(Schema projectedSchema)

Description copied from interface: InternalData.ReadBuilder

Set the projection schema.

Specified by:

project in interface InternalData.ReadBuilder

reuseContainers

public Avro.ReadBuilder reuseContainers()

Description copied from interface: InternalData.ReadBuilder

Reuse container classes, like structs, lists, and maps.

Specified by:

reuseContainers in interface InternalData.ReadBuilder

reuseContainers

public Avro.ReadBuilder reuseContainers(boolean shouldReuse)

rename

public Avro.ReadBuilder rename(String fullName,
 String newName)

setRootType

public InternalData.ReadBuilder setRootType(Class<? extends StructLike> rootClass)

Description copied from interface: InternalData.ReadBuilder

Set a custom class for in-memory objects at the schema root.

Specified by:

setRootType in interface InternalData.ReadBuilder

setCustomType

public InternalData.ReadBuilder setCustomType(int fieldId,
 Class<? extends StructLike> structClass)

Description copied from interface: InternalData.ReadBuilder

Set a custom class for in-memory objects at the given field ID.

Specified by:

setCustomType in interface InternalData.ReadBuilder

withNameMapping

public Avro.ReadBuilder withNameMapping(NameMapping newNameMapping)

classLoader

public Avro.ReadBuilder classLoader(ClassLoader classLoader)

build

public <D> AvroIterable<D> build()

Description copied from interface: InternalData.ReadBuilder

Build the configured reader.

Specified by:

build in interface InternalData.ReadBuilder