Crate risingwave_expr

Modules

• aggregate
• error 🔒
• expr
  Expressions in RisingWave.
• expr_context
• scalar
• sig
  Metadata of expressions.
• table_function
• window_function

Macros

• 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.

Structs

• ContextUnavailable

Enums

• ExprError
  The error type for expression operations.

Type Aliases

• Result
  A specialized Result type for expression operations.

Attribute Macros

• 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.