Skip to main content

write_vector_storage

Function write_vector_storage 

Source
pub async fn write_vector_storage(
    dataset: &Dataset,
    data: impl RecordBatchStream + Unpin + 'static,
    num_rows: u64,
    centroids: FixedSizeListArray,
    pq: ProductQuantizer,
    distance_type: DistanceType,
    column: &str,
    writer: ObjectWriter,
    precomputed_partitions_ds_uri: Option<&str>,
) -> Result<()>