Package org.apache.iceberg.avro

Interface MetricsAwareDatumWriter<D>

All Superinterfaces:
org.apache.avro.io.DatumWriter<D>
All Known Implementing Classes:
DataWriter, FlinkAvroWriter, GenericAvroWriter, InternalWriter, 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
    Description
    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