Skip to main content

Module stream_match_recognize

risingwave_frontend::optimizer::plan_node

Module stream_match_recognize 

Source

Structs§

StreamMatchRecognize
StreamMatchRecognize implements super::Stream for a SQL MATCH_RECOGNIZE (row pattern recognition) operation.

Functions§

lower_pattern 🔒
Lower a bound MatchRecognizePattern (the sqlparser AST) into the structured pattern proto consumed by the executor. Parenthesized groups are flattened (the executor pattern has no group node); anchors (^, $) and exclusions ({- ... -}) are rejected here as they are not yet supported. This replaces the previous text round-trip (Display ↔ a hand-rolled parser).
lower_quantifier 🔒
Map a RepetitionQuantifier to the proto quantifier. *, +, ? map to their dedicated kinds; the {...} forms all map to RANGE with an explicit min and an optional max.