Package org.apache.iceberg.flink.data

Class FlinkAvroWriter

java.lang.Object

org.apache.iceberg.flink.data.FlinkAvroWriter

All Implemented Interfaces:

org.apache.avro.io.DatumWriter<org.apache.flink.table.data.RowData>, MetricsAwareDatumWriter<org.apache.flink.table.data.RowData>

public class FlinkAvroWriter
extends Object
implements MetricsAwareDatumWriter<org.apache.flink.table.data.RowData>

Constructor Summary

Constructors

Constructor	Description
FlinkAvroWriter(org.apache.flink.table.types.logical.RowType rowType)

Method Summary

Modifier and Type	Method	Description
Stream<FieldMetrics>	metrics()	Returns a stream of FieldMetrics that this MetricsAwareDatumWriter keeps track of.
void	setSchema(org.apache.avro.Schema schema)
void	write(org.apache.flink.table.data.RowData 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

Methods inherited from interface org.apache.avro.io.DatumWriter

toByteArray

Constructor Details

FlinkAvroWriter

public FlinkAvroWriter(org.apache.flink.table.types.logical.RowType rowType)

Method Details

setSchema

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

Specified by:

setSchema in interface org.apache.avro.io.DatumWriter<org.apache.flink.table.data.RowData>

write

public void write(org.apache.flink.table.data.RowData datum,
 org.apache.avro.io.Encoder out)
           throws IOException

Specified by:

write in interface org.apache.avro.io.DatumWriter<org.apache.flink.table.data.RowData>

Throws:

IOException

metrics

public Stream<FieldMetrics> metrics()

Description copied from interface: MetricsAwareDatumWriter

Returns a stream of FieldMetrics that this MetricsAwareDatumWriter keeps track of.

Specified by:

metrics in interface MetricsAwareDatumWriter<org.apache.flink.table.data.RowData>