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	createReaderFunc(java.util.function.Function<org.apache.avro.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).

Methods inherited from class java.lang.Object

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

Method Detail

createReaderFunc

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

build

public <D> AvroIterable<D> build()