Crate risingwave_expr

Modules§

bail: Return early with an error, in any type that can be converted from an anyhow::Error.
define_context: Define the context variables which can be used by risingwave expressions.
ensure: Util macro for generating error when condition check failed.
materialized_input_state: AggTypes that are implemented with a materialized input state.
must_have_order_by: AggTypes that must be called with ORDER BY clause. These are slightly different from variants not in result_unaffected_by_order_by, in that variants returned by this macro should be banned while the others should just be warned.
ordered_set: Ordered-set aggregate functions.
result_unaffected_by_distinct: AggTypes of which the aggregate results are not affected by the user given DISTINCT keyword.
result_unaffected_by_order_by: AggTypes of which the aggregate results are not affected by the user given ORDER BY clause.
rewritten: AggTypes that should’ve been rewritten to other kinds. These kinds should not appear when generating physical plan nodes.
simply_cannot_two_phase: AggTypes that are simply cannot 2-phased.
single_value_state: AggTypes that are implemented with a single value state (so-called stateless).
single_value_state_iff_in_append_only: AggTypes that are implemented with a single value state (so-called stateless) iff the input is append-only.
unimplemented_in_stream: AggTypes that are currently not supported in streaming mode.

aggregate
build_aggregate
build_function: Different from #[function], which implements the Expression trait for a rust scalar function, #[build_function] is used when you already implemented Expression manually.
capture_context: Capture the context from the local context to the function impl. TODO: The macro will be merged to #[function(.., capture_context(..))] later.
function: Defining the RisingWave SQL function from a Rust function.