datafusion.ExecutionContext

class datafusion.ExecutionContext

Bases: object

PyExecutionContext is able to plan and execute DataFusion plans. It has a powerful optimizer, a physical planner for local execution, and a multi-threaded execution engine to perform the execution.

__init__()

Initialize self. See help(type(self)) for accurate signature.

Methods

__init__

Initialize self.

catalog

create_dataframe

empty_table

register_csv

register_parquet

register_record_batches

register_udf

sql

Returns a PyDataFrame whose plan corresponds to the SQL statement.

table

tables

catalog()
create_dataframe()
empty_table()
register_csv()
register_parquet()
register_record_batches()
register_udf()
sql()

Returns a PyDataFrame whose plan corresponds to the SQL statement.

table()
tables()