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 Detail

      • metrics

        java.util.stream.Stream<FieldMetrics> metrics()
        Returns a stream of FieldMetrics that this MetricsAwareDatumWriter keeps track of.