Module stream_syntax 

Re-exports

pub use crate::streaming::window::WindowType;

Structs

StreamJoinPattern

Stream join specification

StreamPattern

Stream pattern with variable binding

StreamSource

Stream source specification

WindowSpec

Window specification

Enums

JoinCondition

Join condition between two streams

TemporalOp

Temporal operators for stream joins

Functions

parse_duration

Parse duration: “5 min”, “10 seconds”, “1 hour”, etc.

parse_join_condition

Parse a join condition like “click.user_id == purchase.user_id”

parse_stream_join_pattern

Parse stream join pattern with && operator

parse_stream_pattern

Parse complete stream pattern

parse_stream_source

Parse: from stream(“stream-name”)

parse_window_spec

Parse: over window(5 min, sliding)

parse_window_type

Parse window type: “sliding” or “tumbling”