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.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
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)
-
-
-
Method Detail
-
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()
-
-