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.