public static class Avro.ReadBuilder
extends java.lang.Object
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 |
nameMapping(NameMapping newNameMapping) |
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).
|
public Avro.ReadBuilder createReaderFunc(java.util.function.Function<org.apache.avro.Schema,org.apache.avro.io.DatumReader<?>> readerFunction)
public Avro.ReadBuilder createReaderFunc(java.util.function.BiFunction<Schema,org.apache.avro.Schema,org.apache.avro.io.DatumReader<?>> readerFunction)
public Avro.ReadBuilder split(long newStart, long newLength)
newStart
- the start position for this readnewLength
- the length of the range this read should scanpublic Avro.ReadBuilder project(Schema projectedSchema)
public Avro.ReadBuilder reuseContainers()
public Avro.ReadBuilder reuseContainers(boolean shouldReuse)
public Avro.ReadBuilder rename(java.lang.String fullName, java.lang.String newName)
public Avro.ReadBuilder nameMapping(NameMapping newNameMapping)
public Avro.ReadBuilder classLoader(java.lang.ClassLoader classLoader)
public <D> AvroIterable<D> build()