execute_sql_query

clickhouse_datafusion::sql

Function execute_sql_query 

Source 
pub fn execute_sql_query(
    sql: impl Into<String>,
    pool: Arc<ClickHouseConnectionPool>,
    schema: SchemaRef,
    coerce_schema: bool,
) -> SendableRecordBatchStream
Expand description

Helper function to execute a SQL query and return a stream of record batches.