Struct TemporalLatencyProfile 

pub struct TemporalLatencyProfile {

    pub segment: String,
    pub start_role: TemporalRole,
    pub end_role: TemporalRole,
    pub start_column: String,
    pub end_column: String,
    pub evaluated_rows: usize,
    pub paired_rows: usize,
    pub missing_start: usize,
    pub missing_end: usize,
    pub unparsed_start: usize,
    pub unparsed_end: usize,
    pub negative_count: usize,
    pub zero_count: usize,
    pub p50_seconds: Option<i64>,
    pub p90_seconds: Option<i64>,
    pub p95_seconds: Option<i64>,
    pub p99_seconds: Option<i64>,
    pub max_seconds: Option<i64>,
    pub threshold_seconds: Option<i64>,
    pub above_threshold_count: Option<usize>,
}

Fields

segment: String

start_role: TemporalRole

end_role: TemporalRole

start_column: String

end_column: String

evaluated_rows: usize

Rows in the segment.

paired_rows: usize

Rows with both endpoints present and read: what durations and their counts are out of (not rows less missing ones, since a row can miss both).

missing_start: usize

missing_end: usize

unparsed_start: usize

Text the start column’s format did not read; not counted as missing.

unparsed_end: usize

negative_count: usize

Durations below zero: the end before the start.

zero_count: usize

Durations of exactly zero: the end at the start.

p50_seconds: Option<i64>

p90_seconds: Option<i64>

p95_seconds: Option<i64>

p99_seconds: Option<i64>

max_seconds: Option<i64>

threshold_seconds: Option<i64>

The threshold the breaches were counted against: duration > threshold, strictly, so a duration of exactly the threshold is not a breach.

above_threshold_count: Option<usize>

Implementations

impl TemporalLatencyProfile

pub fn pair(&self) -> (TemporalRole, TemporalRole)

pub fn label(&self) -> String

event to received.

pub fn is_validity(&self) -> bool

A validity period, valid from to valid to: an end before the start is a period that is not valid, and no end is a period still open.

pub fn count( &self, fact: IntervalFact, plan: &DataQualityPlan, ) -> Option<(usize, usize)>

How many rows fact counts, and out of how many. None for a fact this interval does not measure: unparsed text with no format, a threshold not set.

pub fn segment_opens(&self, plan: &DataQualityPlan) -> bool

Whether this interval’s segment is a value its rows can be found by, rather than a stretch of rows or a file.

pub fn evidence_predicate( &self, fact: IntervalFact, plan: &DataQualityPlan, schema: Option<&Schema>, ) -> Option<Expr>

The rows behind fact in this interval’s segment, as a predicate over plan’s scope; None for row-chunk or file segments, or an unmeasured fact. schema, when known, lets a partition segment compare in its column’s type.

Trait Implementations

impl Clone for TemporalLatencyProfile

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TemporalLatencyProfile

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.