Module stream_syntax 

Re-exports

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

Structs

StreamPattern

Stream pattern with variable binding

StreamSource

Stream source specification

WindowSpec

Window specification

Functions

parse_duration

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

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”