SupportsRowPosition

All Known Implementing Classes:: DataReader, FlinkAvroReader, FlinkPlannedAvroReader, GenericAvroReader, InternalReader, NameMappingDatumReader, ProjectionDatumReader, SparkAvroReader, SparkPlannedAvroReader, 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 Summary

Modifier and Type

Method

Description

void

setRowPositionSupplier(Supplier<Long> posSupplier)

Method Details
- setRowPositionSupplier
  
  void setRowPositionSupplier(Supplier<Long> posSupplier)