org.apache.iceberg.flink.data

Class FlinkAvroWriter

java.lang.Object

org.apache.iceberg.data.avro.DataWriter<org.apache.flink.types.Row>

org.apache.iceberg.flink.data.FlinkAvroWriter

All Implemented Interfaces:

org.apache.avro.io.DatumWriter<org.apache.flink.types.Row>

public class FlinkAvroWriter
extends DataWriter<org.apache.flink.types.Row>

Constructor Summary

Constructors

Constructor and Description
FlinkAvroWriter(org.apache.avro.Schema schema)

Method Summary

Modifier and Type	Method and Description
protected ValueWriter<?>	createStructWriter(java.util.List<ValueWriter<?>> fields)

Methods inherited from class org.apache.iceberg.data.avro.DataWriter

create, setSchema, write

Methods inherited from class java.lang.Object

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

Constructor Detail

FlinkAvroWriter

public FlinkAvroWriter(org.apache.avro.Schema schema)

Method Detail

createStructWriter

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

Overrides:

createStructWriter in class DataWriter<org.apache.flink.types.Row>