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.
Arguments passed to CREATE FUNCTION
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
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.
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.
A variadic query operation, Recursive CTE.
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. See
UnnestOptions for more details.
Window its input based on a set of window spec and window function (e.g. SUM or RANK)