ingest_parquet_from_path

rust_data_processing::ingestion::parquet

Function ingest_parquet_from_path 

Source 
pub fn ingest_parquet_from_path(
    path: impl AsRef<Path>,
    schema: &Schema,
) -> IngestionResult<DataSet>
Expand description

Ingest a Parquet file into an in-memory DataSet.

Notes:

  • Validates that all schema fields exist as columns
  • Delegates Parquet decoding to Polars, then converts into DataSet