Aggregates its input based on a set of grouping and aggregate
expressions (e.g. SUM).
Runs the actual plan, and then prints the physical plan with
with execution metrics.
Creates a catalog (aka “Database”).
Creates a schema.
Creates an external table.
Creates an in memory table.
Creates a view.
Apply Cross Join to two logical plans
Describe the schema of table
Removes duplicate rows from the input
The operator that modifies the content of a database (adapted from substrait WriteRel)
Drops a table.
Drops a view.
Produces no rows: An empty relation with an empty schema
Produces a relation with string representations of
various parts of the plan
Extension operator defined outside of DataFusion
Filters rows from its input that do not match an
expression (essentially a WHERE clause with a predicate
expression).
Join two logical plans on one or more join columns
Produces the first n
tuples from its input and discards the rest.
Prepare a statement but do not execute it. Prepare statements can have 0 or more
Expr::Placeholder
expressions that are filled in during execution
Evaluates an arbitrary list of expressions (essentially a
SELECT with an expression list) on its input.
Repartition the plan based on a partitioning scheme.
Sorts its input according to a list of sort expressions.
Represents some sort of execution plan, in String form
Subquery
Aliased subquery
Produces rows from a table provider by reference or from the context
Union multiple inputs
Unnest a column that contains a nested list type.
Window its input based on a set of window spec and window function (e.g. SUM or RANK)