pub struct JoinCoverageConstraint { /* private fields */ }Expand description
Join coverage constraint for validating the quality of table joins.
This constraint measures what percentage of rows from the left table successfully join with the right table, helping identify:
- Missing reference data
- Data quality issues in foreign key relationships
- Incomplete data loads
- Orphaned records
The constraint supports:
- Single and composite join keys
- Configurable expected match rates
- Detailed mismatch reporting
- Inner, left, and right join coverage analysis
Implementations§
Source§impl JoinCoverageConstraint
impl JoinCoverageConstraint
Sourcepub fn on(
self,
left_column: impl Into<String>,
right_column: impl Into<String>,
) -> Self
pub fn on( self, left_column: impl Into<String>, right_column: impl Into<String>, ) -> Self
Set the join key columns.
§Arguments
left_column- Column in the left tableright_column- Column in the right table
Sourcepub fn on_multiple(
self,
keys: Vec<(impl Into<String>, impl Into<String>)>,
) -> Self
pub fn on_multiple( self, keys: Vec<(impl Into<String>, impl Into<String>)>, ) -> Self
Set multiple join key columns for composite joins.
§Arguments
keys- Vector of (left_column, right_column) pairs
Sourcepub fn expect_match_rate(self, rate: f64) -> Self
pub fn expect_match_rate(self, rate: f64) -> Self
Set the expected match rate.
§Arguments
rate- Expected percentage of rows that should match (0.0 to 1.0)
Sourcepub fn coverage_type(self, coverage_type: CoverageType) -> Self
pub fn coverage_type(self, coverage_type: CoverageType) -> Self
Set the coverage type to check.
Sourcepub fn distinct_only(self, distinct: bool) -> Self
pub fn distinct_only(self, distinct: bool) -> Self
Count only distinct values when calculating coverage.
Sourcepub fn max_examples_reported(self, max_examples: usize) -> Self
pub fn max_examples_reported(self, max_examples: usize) -> Self
Set the maximum number of unmatched examples to report.
Trait Implementations§
Source§impl Clone for JoinCoverageConstraint
impl Clone for JoinCoverageConstraint
Source§fn clone(&self) -> JoinCoverageConstraint
fn clone(&self) -> JoinCoverageConstraint
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Constraint for JoinCoverageConstraint
impl Constraint for JoinCoverageConstraint
Source§fn evaluate<'life0, 'life1, 'async_trait>(
&'life0 self,
ctx: &'life1 SessionContext,
) -> Pin<Box<dyn Future<Output = Result<ConstraintResult>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn evaluate<'life0, 'life1, 'async_trait>(
&'life0 self,
ctx: &'life1 SessionContext,
) -> Pin<Box<dyn Future<Output = Result<ConstraintResult>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Evaluates the constraint against the data in the session context. Read more
Source§fn column(&self) -> Option<&str>
fn column(&self) -> Option<&str>
Returns the column this constraint operates on (if single-column). Read more
Source§fn description(&self) -> Option<&str>
fn description(&self) -> Option<&str>
Returns a description of what this constraint validates. Read more
Source§fn metadata(&self) -> ConstraintMetadata
fn metadata(&self) -> ConstraintMetadata
Returns the metadata associated with this constraint. Read more
Source§impl Debug for JoinCoverageConstraint
impl Debug for JoinCoverageConstraint
Source§impl<'de> Deserialize<'de> for JoinCoverageConstraint
impl<'de> Deserialize<'de> for JoinCoverageConstraint
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Auto Trait Implementations§
impl Freeze for JoinCoverageConstraint
impl RefUnwindSafe for JoinCoverageConstraint
impl Send for JoinCoverageConstraint
impl Sync for JoinCoverageConstraint
impl Unpin for JoinCoverageConstraint
impl UnwindSafe for JoinCoverageConstraint
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more