_write_records_spark

Internal helper

This page documents an internal implementation helper, not a primary public API.

Source code in src/fabricops_kit/quality.py

def _write_records_spark(spark, records: list[dict], table: str, mode: str = "append") -> None:
    if records:
        write_metadata_records(records, table, writer=lambda rows, t, mode="append", **_: spark.createDataFrame(rows).write.mode(mode).saveAsTable(t), mode=mode)