public class AvroRowDatumReader extends Object implements org.apache.avro.io.DatumReader<InternalRow>
DatumReader
for reading InternalRow
.Constructor and Description |
---|
AvroRowDatumReader(RowType projectedRowType) |
Modifier and Type | Method and Description |
---|---|
InternalRow |
read(InternalRow reuse,
org.apache.avro.io.Decoder in) |
void |
setSchema(org.apache.avro.Schema schema) |
public AvroRowDatumReader(RowType projectedRowType)
public void setSchema(org.apache.avro.Schema schema)
setSchema
in interface org.apache.avro.io.DatumReader<InternalRow>
public InternalRow read(InternalRow reuse, org.apache.avro.io.Decoder in) throws IOException
read
in interface org.apache.avro.io.DatumReader<InternalRow>
IOException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.