Interface BaseFormatModel.WriterFunction<W,S,F>

Type Parameters:
W - the file format specific writer type to be created
S - the engine-specific schema type describing the input 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.WriterFunction<W,S,F>
A functional interface for creating writers that can write data in a specific format.
  • Method Summary

    Modifier and Type
    Method
    Description
    write(Schema icebergSchema, F fileSchema, S engineSchema)
    Creates a writer for the given schemas.
  • Method Details

    • write

      W write(Schema icebergSchema, F fileSchema, S engineSchema)
      Creates a writer for the given schemas.
      Parameters:
      icebergSchema - the Iceberg schema defining the table structure
      fileSchema - the file format specific target schema for the output files
      engineSchema - the engine-specific schema for the input data (optional)
      Returns:
      a writer configured for the given schemas