Module sql

clickhouse_datafusion

Module sql

Expand description

§`ClickHouse` SQL `DataFusion` `TableProvider`

This module implements a SQL TableProvider for DataFusion.

This is used as a fallback if the datafusion-federation optimizer is not enabled.

Structs§

ClickHouseSqlExec: A custom ExecutionPlan for SqlTables.
SqlTable: A TableProvider for remote ClickHouse sql tables.

Enums§

JoinPushDown: Controls whether join pushdown is allowed, and under what conditions

Functions§

execute_sql_query: Helper function to execute a SQL query and return a stream of record batches.
project_schema_safe: Project a schema safely, taking into account empty columns