Skip to main content

Module stream

Module stream 

Source

Structsยง

NestedSchemaAligner
Aligns projected batches to the expected output schema for nested projections.
ParquetErrorAdapter ๐Ÿ”’
Maps parquet stream errors into mito errors before batches enter the filler.

Functionsยง

align_array ๐Ÿ”’
align_batch_to_schema ๐Ÿ”’
fill_missing_cols ๐Ÿ”’

Type Aliasesยง

ProjectedRecordBatchStream ๐Ÿ”’