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 schema
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.
Builder for logical plans
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
Indicator that any current transaction should be terminated
Indicator that the following statements should be committed or rolled back atomically
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)