pub fn register_streaming_functions(ctx: &SessionContext)Expand description
Registers LaminarDB streaming UDFs with a session context.
Registers the following scalar functions:
tumble(timestamp, interval)— tumbling window starthop(timestamp, slide, size)— hopping window startsession(timestamp, gap)— session window pass-throughwatermark()— current watermark (returns NULL, no live source)
Use register_streaming_functions_with_watermark to provide a
live watermark source from Ring 0.