Method add_matched_batch

crates/paimon/src/table/data_evolution_writer.rs:127–138

Add a batch of matched rows. The batch must contain: - A non-null `_ROW_ID` column (Int64) identifying which rows to update - One column for each entry in `update_columns` with the new values

(&mut self, batch: RecordBatch)

    /// - A non-null `_ROW_ID` column (Int64) identifying which rows to update
    /// - One column for each entry in `update_columns` with the new values
    pub fn add_matched_batch(&mut self, batch: RecordBatch) -> Result<()> {
        if batch.num_rows() == 0 {
            return Ok(());
        }

        let row_id_col = row_id_column(&batch)?;
        validate_row_id_not_null(row_id_col)?;
        validate_update_columns(&batch, &self.update_columns)?;

        self.matched_batches.push(batch);
        Ok(())
    }

    /// Scan file metadata, group matched rows by file, read originals,
    /// apply updates, and write partial-column files.