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 Description
  
  FlinkAvroWriter(org.apache.avro.Schema schema)
- Method Summary
  
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method 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>