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 |
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) |
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 withNameMapping(NameMapping newNameMapping)
public Avro.ReadBuilder classLoader(java.lang.ClassLoader classLoader)
public <D> AvroIterable<D> build()