Module logical_plan

Re-exports

• pub use self::accumulator::Accumulator;
• pub use self::accumulator::AggregateFunctionCreator;
• pub use self::accumulator::AggregateFunctionCreatorRef;

Modules

• accumulator
  Accumulator module contains the trait definition for aggregation function’s accumulators.
• expr 🔒
• udaf 🔒
  Udaf module contains functions and structs supporting user-defined aggregate functions.

Structs

• AggregateFunction
  Logical representation of a user-defined aggregate function (UDAF) A UDAF is different from a UDF in that it is stateful across batches.

Traits

• SubstraitPlanDecoder
  The datafusion [LogicalPlan] decoder.

Functions

• build_filter_from_timestamp
  Builds an Expr that filters timestamp column from given timestamp range. Returns None if time range is None or full time range.
• build_same_type_ts_filter
  Builds a filter for a timestamp column with the same type as the timestamp column. Returns None if time range is None or full time range.
• create_aggregate_function
• rename_logical_plan_columns
  Rename columns by applying a new projection. Returns an error if the column to be renamed does not exist. The renames parameter is a Vector with elements in the form of (old_name, new_name).

Type Aliases

• SubstraitPlanDecoderRef