Struct StreamMatchRecognize 

pub struct StreamMatchRecognize {
    pub base: PlanBase<Stream>,
    core: MatchRecognize<PlanRef<Stream>>,
}

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

Fields

base: PlanBase<Stream>

core: MatchRecognize<PlanRef<Stream>>

Implementations

impl StreamMatchRecognize

pub fn new(core: MatchRecognize<PlanRef<Stream>>) -> Self

fn infer_state_table(&self) -> TableCatalog

Per-partition buffered-row state table. Layout: [ seq (i64) , <input columns..> ] keyed by (partition columns, ORDER BY columns, seq). Keying by the order columns keeps the state physically sorted by (partition, order key), so the watermark pass can scan it in PK order — rows arrive grouped by partition and already ordered within each partition — and process one partition at a time without an in-memory sort. The executor buffers the raw input row per live row and restores the buffer from here on recovery. seq is a per-actor monotonic id that breaks ties between rows with equal ORDER BY keys; consumed rows are deleted after the scan. DEFINE predicates and MEASURES are both evaluated at match time from the stored input rows, so neither is persisted. The partition and order-key columns are columns of the stored input row, so they are not stored separately.

The whole input row is stored for simplicity. A future optimization could project to only the columns actually referenced (partition / order keys plus the columns read by DEFINE and MEASURES), shrinking per-row state at the cost of a column-remapping layer between the stored row and the slot indices. Deferred until state size warrants it.

fn input(&self) -> PlanRef<Stream>

fn clone_with_input(&self, input: PlanRef<Stream>) -> Self

Methods from Deref<Target = PlanBase<Stream>>

pub fn clone_with_new_plan_id(&self) -> Self

pub fn clone_with_new_distribution(&self, dist: Distribution) -> Self

Clone the plan node with a new distribution.

Panics if the plan node is not physical.

Trait Implementations

impl Clone for StreamMatchRecognize

fn clone(&self) -> StreamMatchRecognize

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamMatchRecognize

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

Formats the value using the given formatter.

impl Deref for StreamMatchRecognize

type Target = PlanBase<Stream>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl Distill for StreamMatchRecognize

fn distill<'a>(&self) -> XmlNode<'a>

fn distill_to_string(&self) -> String

impl Eq for StreamMatchRecognize

impl ExprRewritable<Stream> for StreamMatchRecognize

fn has_rewritable_expr(&self) -> bool

fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef<Stream>

impl ExprVisitable for StreamMatchRecognize

fn visit_exprs(&self, v: &mut dyn ExprVisitor)

impl Hash for StreamMatchRecognize

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for StreamMatchRecognize

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl PlanNodeMeta for StreamMatchRecognize

const NODE_TYPE: StreamPlanNodeType = StreamPlanNodeType::StreamMatchRecognize

type Convention = Stream

fn plan_base(&self) -> &PlanBase<Stream>

Get the reference to the PlanBase with corresponding convention.

impl PlanTreeNode<Stream> for StreamMatchRecognize

fn clone_with_inputs(&self, inputs: &[PlanRef<Stream>]) -> PlanRef<Stream>

Clone the node with a list of new inputs.

fn inputs(&self) -> SmallVec<[PlanRef<Stream>; 2]>

Get input nodes of the plan.

impl StreamPlanNode for StreamMatchRecognize

impl StructuralPartialEq for StreamMatchRecognize

impl TryToStreamPb for StreamMatchRecognize

fn try_to_stream_prost_body( &self, state: &mut BuildFragmentGraphState, ) -> Result<NodeBody, SchedulerError>