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()¶

ExecutionContext

Expression