Skip to content

yggdrasil.spark.frame

frame

spark_typed_cast 

spark_typed_cast(
    objects_per_batch: Iterator[list[Any]], schema: Schema, *, byte_size: int
) -> Iterator[pa.RecordBatch]

Cast batched Python objects into Arrow batches matching schema.