Struct TemporalProbeSchedule 

pub struct TemporalProbeSchedule { /* private fields */ }

Validated target-time schedule for one temporal-join state machine.

Implementations

impl TemporalProbeSchedule

pub fn as_of() -> Self

One lookup at the left row’s event time.

pub fn list(offsets_ms: Vec<i64>) -> Result<Self, String>

Build a validated explicit schedule.

Errors

Returns an error for an empty list, duplicate offsets, or parser-limit violations.

pub fn range(start_ms: i64, end_ms: i64, step_ms: i64) -> Result<Self, String>

Build a validated inclusive range schedule.

Errors

Returns an error for invalid bounds, a non-positive step, a range that is not exactly divisible by its step, or parser-limit violations.

pub fn len(&self) -> usize

Number of target-time probes produced per left row.

pub fn is_empty(&self) -> bool

Whether this schedule contains no probes.

pub fn offsets_ms(&self) -> &[i64]

Deterministic offsets in milliseconds.

pub const fn is_multi_horizon(&self) -> bool

Whether the syntax requested typed offset_ms and probe_time outputs.

Trait Implementations

impl Clone for TemporalProbeSchedule

fn clone(&self) -> TemporalProbeSchedule

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TemporalProbeSchedule

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

Formats the value using the given formatter.

impl Eq for TemporalProbeSchedule

impl PartialEq for TemporalProbeSchedule

fn eq(&self, other: &TemporalProbeSchedule) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for TemporalProbeSchedule