pub struct MatchRecognizeStatement {
pub source_table: String,
pub key_column: String,
pub event_time_column: String,
pub pattern: CompiledPattern,
}Expand description
Parsed MATCH_RECOGNIZE statement.
Parsed MATCH_RECOGNIZE statement ready for execution.
§Window boundary semantics
The WITHIN clause sets a window duration in milliseconds. The expiry
check uses a strict greater-than comparison:
event_time_ms - partial.start_time_ms > window_ms.
This means an event arriving at exactly start_time + window_ms is
still considered within the window and will advance (or complete) the
partial match. Only events arriving strictly after that point cause the
partial to expire and be discarded.
Fields§
§source_table: String§key_column: String§event_time_column: String§pattern: CompiledPatternTrait Implementations§
Source§impl Clone for MatchRecognizeStatement
impl Clone for MatchRecognizeStatement
Source§fn clone(&self) -> MatchRecognizeStatement
fn clone(&self) -> MatchRecognizeStatement
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl Freeze for MatchRecognizeStatement
impl RefUnwindSafe for MatchRecognizeStatement
impl Send for MatchRecognizeStatement
impl Sync for MatchRecognizeStatement
impl Unpin for MatchRecognizeStatement
impl UnsafeUnpin for MatchRecognizeStatement
impl UnwindSafe for MatchRecognizeStatement
Blanket Implementations§
impl<T> Allocation for T
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request