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.
Represent the unnesting operation on a list column, such as the recursion depth and
the output column name after unnesting
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.
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
Execute a prepared statement.
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
Basic TableSource implementation intended for use in tests and documentation. It is expected
that users will provide their own TableSource implementations or use DataFusion’s
DefaultTableSource.
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.
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)