Skip to main content

align_parts

Function align_parts 

Source
fn align_parts(parts: &[BulkPart]) -> Result<(SchemaRef, Vec<DfRecordBatch>)>
Expand description

Align the JSON columns in BulkParts, to unified Arrow arrays. So that we can compute (concat, sort, etc.) on them.