Struct DeltaDataChecker

pub struct DeltaDataChecker { /* private fields */ }

Responsible for checking batches of data conform to table’s invariants, constraints and nullability.

Implementations

impl DeltaDataChecker

pub fn empty() -> Self

Create a new DeltaDataChecker with no invariants or constraints

pub fn new_with_invariants(invariants: Vec<Invariant>) -> Self

Create a new DeltaDataChecker with a specified set of invariants

pub fn new_with_constraints(constraints: Vec<Constraint>) -> Self

Create a new DeltaDataChecker with a specified set of constraints

pub fn with_session_context(self, context: SessionContext) -> Self

Specify the Datafusion context

pub fn with_extra_constraints(self, constraints: Vec<Constraint>) -> Self

Add the specified set of constraints to the current DeltaDataChecker’s constraints

pub fn new(snapshot: &DeltaTableState) -> Self

Create a new DeltaDataChecker

pub async fn check_batch( &self, record_batch: &RecordBatch, ) -> Result<(), DeltaTableError>

Check that a record batch conforms to table’s invariants.

If it does not, it will return DeltaTableError::InvalidData with a list of values that violated each invariant.

Trait Implementations

impl Clone for DeltaDataChecker

fn clone(&self) -> DeltaDataChecker

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for DeltaDataChecker

fn default() -> DeltaDataChecker

Returns the “default value” for a type.