fn filter_deleted_from_batch(
batch: RecordBatch,
metrics: &mut DedupMetrics,
) -> Result<RecordBatch>Expand description
Removes deleted rows from the batch and updates metrics.
fn filter_deleted_from_batch(
batch: RecordBatch,
metrics: &mut DedupMetrics,
) -> Result<RecordBatch>Removes deleted rows from the batch and updates metrics.