public class ProjectionDatumReader<D> extends java.lang.Object implements org.apache.avro.io.DatumReader<D>, SupportsRowPosition
Constructor and Description |
---|
ProjectionDatumReader(java.util.function.Function<org.apache.avro.Schema,org.apache.avro.io.DatumReader<?>> getReader,
Schema expectedSchema,
java.util.Map<java.lang.String,java.lang.String> renames,
NameMapping nameMapping) |
Modifier and Type | Method and Description |
---|---|
D |
read(D reuse,
org.apache.avro.io.Decoder in) |
void |
setRowPositionSupplier(java.util.function.Supplier<java.lang.Long> posSupplier) |
void |
setSchema(org.apache.avro.Schema newFileSchema) |
public ProjectionDatumReader(java.util.function.Function<org.apache.avro.Schema,org.apache.avro.io.DatumReader<?>> getReader, Schema expectedSchema, java.util.Map<java.lang.String,java.lang.String> renames, NameMapping nameMapping)
public void setRowPositionSupplier(java.util.function.Supplier<java.lang.Long> posSupplier)
setRowPositionSupplier
in interface SupportsRowPosition
public void setSchema(org.apache.avro.Schema newFileSchema)
setSchema
in interface org.apache.avro.io.DatumReader<D>