org.apache.paimon.format.avro

Class AvroRowDatumWriter

java.lang.Object

org.apache.paimon.format.avro.AvroRowDatumWriter

All Implemented Interfaces:

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

public class AvroRowDatumWriter
extends Object
implements org.apache.avro.io.DatumWriter<InternalRow>

A DatumWriter for writing InternalRow.

Constructor Summary

Constructors

Constructor and Description
AvroRowDatumWriter(RowType rowType)

Method Summary

Modifier and Type	Method and Description
void	setSchema(org.apache.avro.Schema schema)
void	write(InternalRow datum, org.apache.avro.io.Encoder out)

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroRowDatumWriter

public AvroRowDatumWriter(RowType rowType)

Method Detail

setSchema

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

Specified by:

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

write

public void write(InternalRow datum,
                  org.apache.avro.io.Encoder out)
           throws IOException

Specified by:

write in interface org.apache.avro.io.DatumWriter<InternalRow>

Throws:

IOException