Carli: Created page with "← Back to Full SCM API documentation == stream_emit == invokes a streaming callback immediately; marks ordering-sensitive emission as an observable effect '''Allowed number of parameters:''' 2–2 === Parameters === * '''emit''' (`func(value:any) -> any`): * '''value''' (`any`): === Returns === `any` == stream_window_reduce == applies OFFSET/LIMIT and a serial redu..."

2026-08-27T06:38:43Z

Created page with "← Back to Full SCM API documentation == stream_emit == invokes a streaming callback immediately; marks ordering-sensitive emission as an observable effect '''Allowed number of parameters:''' 2–2 === Parameters === * '''emit''' (<code>func(value:any) -> any</code>): * '''value''' (<code>any</code>): === Returns === <code>any</code> == stream_window_reduce == applies OFFSET/LIMIT and a serial redu..."

New page

← Back to [[Full SCM API documentation]]

== stream_emit ==

invokes a streaming callback immediately; marks ordering-sensitive emission as an observable effect

'''Allowed number of parameters:''' 2–2


=== Parameters ===

* '''emit''' (<code>func(value:any) -> any</code>):
* '''value''' (<code>any</code>):


=== Returns ===

<code>any</code>

== stream_window_reduce ==

applies OFFSET/LIMIT and a serial reducer to complete values emitted by a nested streaming producer without collecting an intermediate relation

'''Allowed number of parameters:''' 5–5


=== Parameters ===

* '''offset''' (<code>number</code>): number of complete producer values to skip
* '''limit''' (<code>number</code>): maximum values to reduce, or -1 for no limit
* '''reduce''' (<code>func(acc:any, value:any) -> any</code>): serial accumulator over complete values
* '''neutral''' (<code>any</code>): initial accumulator
* '''producer''' (<code>func(emit:func) -> any</code>): nested streaming plan called with a one-value emit callback


=== Returns ===

<code>any</code>

== window_mut ==

Ring buffer shift-insert for window functions. (window_mut window emit_fn vals) writes vals (a list of stride values) into the current slot, increments counter. If skip>0, decrements skip. Otherwise calls (emit_fn oldest_v0 oldest_v1 ... newest_v0 newest_v1) with all slot values ordered oldest-to-newest. Returns updated window.

'''Allowed number of parameters:''' 3–3


=== Parameters ===

* '''window''' (<code>list</code>): ring buffer accumulator
* '''emit_fn''' (<code>func(values:any...) -> any</code>): callback receiving all window values oldest-to-newest
* '''vals''' (<code>list</code>): list of stride values to insert


=== Returns ===

<code>list</code>

== window_flush ==

Flush remaining window buffer by shifting in nils. (window_flush window emit_fn count) shifts in count positions of nils, calling emit_fn for each displaced position. Returns nil.

'''Allowed number of parameters:''' 3–3


=== Parameters ===

* '''window''' (<code>list</code>): ring buffer accumulator
* '''emit_fn''' (<code>func(values:any...) -> any</code>): callback receiving all window values oldest-to-newest
* '''count''' (<code>number</code>): number of nil positions to shift in


=== Returns ===

<code>nil</code>

== show_processlist ==

returns a list of active sessions for SHOW [FULL] PROCESSLIST; pass true for full info

'''Allowed number of parameters:''' 0–1


=== Parameters ===

* '''full''' (<code>bool</code>): if true, include full Info text ''(optional)''


=== Returns ===

<code>list</code>

== connection_id ==

returns the process-list ID of the current session (MySQL CONNECTION_ID() equivalent)

'''Allowed number of parameters:''' 0–0


=== Parameters ===

''This function has no parameters.''


=== Returns ===

<code>int</code>

== kill_query ==

cancel the running query in session id; returns true if a query was killed

'''Allowed number of parameters:''' 1–1


=== Parameters ===

* '''id''' (<code>int</code>): session ID from SHOW PROCESSLIST


=== Returns ===

<code>bool</code>

Window Functions - Revision history