Function wrap_with_row_id_and_delete

Source
pub fn wrap_with_row_id_and_delete(
    stream: ReadBatchTaskStream,
    fragment_id: u32,
    config: RowIdAndDeletesConfig,
) -> ReadBatchFutStream
Expand description

Given a stream of batch tasks this function will add a row ids column (if requested) and also apply a deletions vector to the batch.

This converts from BatchTaskStream to BatchFutStream because, if we are applying a deletion vector, it is impossible to know how many output rows we will have.