Struct PartitionedCepMatcher 

pub struct PartitionedCepMatcher<K>
where
    K: Hash + Eq + Clone + Ord,
{ /* private fields */ }

Partitioned wrapper routing events to per-key SequentialPatternMatcher instances (P3-27).

Implementations

impl<K> PartitionedCepMatcher<K>

where K: Hash + Eq + Clone + Ord,

pub fn new(pattern: CompiledPattern) -> Self

pub fn process_event( &mut self, key: K, stage_name: &str, batch: RecordBatch, event_time_ms: i64, ) -> Vec<Vec<RecordBatch>>

pub fn evict_keys_before(&mut self, cutoff_ms: i64)

Remove all keys whose most recent event time is strictly before cutoff_ms. Called by the streaming CEP path after each batch to bound memory for high-cardinality key spaces.

pub fn partition_count(&self) -> usize

Number of currently tracked partition keys.

pub fn partial_signature(&self, key: &K) -> Option<(usize, i64)>

(stage_index, start_time_ms) of this key’s live partial match, if any.

Callers that do not know which pattern stage an incoming row represents feed the row to each stage name in order, and must stop as soon as the row has been consumed. Comparing this signature before and after Self::process_event is how they detect consumption — it changes when a partial starts, advances, or restarts after expiry (where stage_index stays 0 but start_time_ms moves).

Without that check the same row starts a partial at stage 0 and is then advanced through every remaining stage, fabricating a complete match out of a single event.

Trait Implementations

impl<K> Clone for PartitionedCepMatcher<K>

where K: Hash + Eq + Clone + Ord + Clone,

fn clone(&self) -> PartitionedCepMatcher<K>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<K> Debug for PartitionedCepMatcher<K>

where K: Hash + Eq + Clone + Ord + Debug,

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

Formats the value using the given formatter.