Package org.apache.iceberg.data.avro

Class DataWriter<T>

java.lang.Object

org.apache.iceberg.data.avro.DataWriter<T>

All Implemented Interfaces:

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

Direct Known Subclasses:

FlinkAvroWriter

public class DataWriter<T>
extends java.lang.Object
implements org.apache.avro.io.DatumWriter<T>

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DataWriter(org.apache.avro.Schema schema)

Method Summary

Modifier and Type	Method	Description
static <D> DataWriter<D>	create(org.apache.avro.Schema schema)
protected ValueWriter<?>	createStructWriter(java.util.List<ValueWriter<?>> fields)
void	setSchema(org.apache.avro.Schema schema)
void	write(T 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

DataWriter

protected DataWriter(org.apache.avro.Schema schema)

Method Detail

create

public static <D> DataWriter<D> create(org.apache.avro.Schema schema)

setSchema

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

Specified by:

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

write

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

Specified by:

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

Throws:

java.io.IOException

createStructWriter

protected ValueWriter<?> createStructWriter(java.util.List<ValueWriter<?>> fields)