Interface SupportsRowPosition

All Known Implementing Classes:
DataReader, FlinkAvroReader, GenericAvroReader, NameMappingDatumReader, ProjectionDatumReader, SparkAvroReader, ValueReaders.PlannedStructReader, ValueReaders.StructReader

public interface SupportsRowPosition
Interface for readers that accept a callback to determine the starting row position of an Avro split.
  • Method Details

    • setRowPositionSupplier

      void setRowPositionSupplier(Supplier<Long> posSupplier)