public class ProjectionDatumReader<D>
extends java.lang.Object
implements org.apache.avro.io.DatumReader<D>
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 |
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 setSchema(org.apache.avro.Schema newFileSchema)
setSchema
in interface org.apache.avro.io.DatumReader<D>