datafusion_physical_plan::execution_plan

Function check_not_null_constraints

Source 
pub fn check_not_null_constraints(
    batch: RecordBatch,
    column_indices: &Vec<usize>,
) -> Result<RecordBatch>
Expand description

Checks a RecordBatch for not null constraints on specified columns.

§Arguments

  • batch - The RecordBatch to be checked
  • column_indices - A vector of column indices that should be checked for not null constraints.

§Returns

  • Result<RecordBatch> - The original RecordBatch if all constraints are met

This function iterates over the specified column indices and ensures that none of the columns contain null values. If any column contains null values, an error is returned.