Module logical_plan

Re-exports§

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.

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

add_insert_to_logical_plan: create a insert into table_name <input> logical plan
breakup_insert_plan: Convert a insert into logical plan to an (table_name, logical_plan) where table_name is the name of the table to insert into. logical_plan is the plan to be executed.
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).