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.