org.apache.iceberg.avro

Class Avro.ReadBuilder

java.lang.Object

org.apache.iceberg.avro.Avro.ReadBuilder

Enclosing class:

Avro

public static class Avro.ReadBuilder
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
<D> AvroIterable<D>	build()
Avro.ReadBuilder	classLoader(java.lang.ClassLoader classLoader)
Avro.ReadBuilder	createReaderFunc(java.util.function.BiFunction<Schema,org.apache.avro.Schema,org.apache.avro.io.DatumReader<?>> readerFunction)
Avro.ReadBuilder	createReaderFunc(java.util.function.Function<org.apache.avro.Schema,org.apache.avro.io.DatumReader<?>> readerFunction)
Avro.ReadBuilder	createResolvingReader(java.util.function.Function<Schema,org.apache.avro.io.DatumReader<?>> readerFunction)
Avro.ReadBuilder	project(Schema projectedSchema)
Avro.ReadBuilder	rename(java.lang.String fullName, java.lang.String newName)
Avro.ReadBuilder	reuseContainers()
Avro.ReadBuilder	reuseContainers(boolean shouldReuse)
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 Detail

createResolvingReader

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

createReaderFunc

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

createReaderFunc

public Avro.ReadBuilder createReaderFunc(java.util.function.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).

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)

reuseContainers

public Avro.ReadBuilder reuseContainers()

reuseContainers

public Avro.ReadBuilder reuseContainers(boolean shouldReuse)

rename

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

withNameMapping

public Avro.ReadBuilder withNameMapping(NameMapping newNameMapping)

classLoader

public Avro.ReadBuilder classLoader(java.lang.ClassLoader classLoader)

build

public <D> AvroIterable<D> build()