Interface BaseFormatModel.ReaderFunction<R,S,F>

Type Parameters:
R - the file format specific reader type to be created
S - the engine-specific schema type describing the output data
F - the file schema type used by the underlying file format
Enclosing class:
BaseFormatModel<D,S,W,R,F>
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface public static interface BaseFormatModel.ReaderFunction<R,S,F>
A functional interface for creating readers that can read data from a specific format.
  • Method Summary

    Modifier and Type
    Method
    Description
    read(Schema icebergSchema, F fileSchema, S engineSchema, Map<Integer,?> idToConstant)
    Creates a reader for the given schemas.
  • Method Details

    • read

      R read(Schema icebergSchema, F fileSchema, S engineSchema, Map<Integer,?> idToConstant)
      Creates a reader for the given schemas.
      Parameters:
      icebergSchema - the Iceberg schema defining the table structure
      fileSchema - the schema that the file was written with, although it can be null in the case of Avro files because it is passed in later
      engineSchema - the engine-specific schema for the output data (optional)
      idToConstant - a map of field IDs to constant values for partition columns and other fields not stored in data files
      Returns:
      a reader configured for the given schemas