org.apache.iceberg.avro

Interface MetricsAwareDatumWriter<D>

All Superinterfaces:

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

All Known Implementing Classes:

DataWriter, FlinkAvroWriter, SparkAvroWriter

public interface MetricsAwareDatumWriter<D>
extends org.apache.avro.io.DatumWriter<D>

Wrapper writer around DatumWriter with metrics support.

Method Summary

Modifier and Type	Method and Description
java.util.stream.Stream<FieldMetrics>	metrics() Returns a stream of FieldMetrics that this MetricsAwareDatumWriter keeps track of.

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

setSchema, write

Method Detail

metrics

java.util.stream.Stream<FieldMetrics> metrics()

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