public class AvroRowDatumWriter extends Object implements org.apache.avro.io.DatumWriter<InternalRow>
DatumWriter
for writing InternalRow
.Constructor and Description |
---|
AvroRowDatumWriter(RowType rowType) |
Modifier and Type | Method and Description |
---|---|
void |
setSchema(org.apache.avro.Schema schema) |
void |
write(InternalRow datum,
org.apache.avro.io.Encoder out) |
public AvroRowDatumWriter(RowType rowType)
public void setSchema(org.apache.avro.Schema schema)
setSchema
in interface org.apache.avro.io.DatumWriter<InternalRow>
public void write(InternalRow datum, org.apache.avro.io.Encoder out) throws IOException
write
in interface org.apache.avro.io.DatumWriter<InternalRow>
IOException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.