org.apache.paimon.format.avro

Class AvroRowDatumReader

java.lang.Object

org.apache.paimon.format.avro.AvroRowDatumReader

All Implemented Interfaces:

org.apache.avro.io.DatumReader<InternalRow>

public class AvroRowDatumReader
extends Object
implements org.apache.avro.io.DatumReader<InternalRow>

A DatumReader for reading InternalRow.

Constructor Summary

Constructors

Constructor and Description
AvroRowDatumReader(RowType projectedRowType)

Method Summary

Modifier and Type	Method and Description
InternalRow	read(InternalRow reuse, org.apache.avro.io.Decoder in)
void	setSchema(org.apache.avro.Schema schema)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AvroRowDatumReader

public AvroRowDatumReader(RowType projectedRowType)

Method Detail

setSchema

public void setSchema(org.apache.avro.Schema schema)

Specified by:

setSchema in interface org.apache.avro.io.DatumReader<InternalRow>

read

public InternalRow read(InternalRow reuse,
                        org.apache.avro.io.Decoder in)
                 throws IOException

Specified by:

read in interface org.apache.avro.io.DatumReader<InternalRow>

Throws:

IOException