Package 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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <D> AvroIterable<D>build()Avro.ReadBuilderclassLoader(java.lang.ClassLoader classLoader)Avro.ReadBuildercreateReaderFunc(java.util.function.BiFunction<Schema,org.apache.avro.Schema,org.apache.avro.io.DatumReader<?>> readerFunction)Avro.ReadBuildercreateReaderFunc(java.util.function.Function<org.apache.avro.Schema,org.apache.avro.io.DatumReader<?>> readerFunction)Avro.ReadBuildercreateResolvingReader(java.util.function.Function<Schema,org.apache.avro.io.DatumReader<?>> readerFunction)Avro.ReadBuilderproject(Schema projectedSchema)Avro.ReadBuilderrename(java.lang.String fullName, java.lang.String newName)Avro.ReadBuilderreuseContainers()Avro.ReadBuilderreuseContainers(boolean shouldReuse)Avro.ReadBuildersplit(long newStart, long newLength)Restricts the read to the given range: [start, end = start + length).Avro.ReadBuilderwithNameMapping(NameMapping newNameMapping)
-
-
-
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 readnewLength- 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()
-
-