Skip to main content

execute_match_recognize

Function execute_match_recognize 

Source
pub fn execute_match_recognize(
    stmt: MatchRecognizeStatement,
    source_batches: &[RecordBatch],
) -> SqlResult<Vec<RecordBatch>>
Expand description

Execute a MATCH_RECOGNIZE statement against pre-collected source batches.

For each partition key, events are fed to a SequentialPatternMatcher in event-time order. Completed pattern matches are concatenated and returned as a single output RecordBatch per match (one row per stage event).

This function buffers all source rows in memory, which is incompatible with unbounded streaming sources. For streaming sources, use execute_streaming_match_recognize instead.