datafusion_table_providers::sql::sql_provider_datafusion

Function get_stream

Source 
pub async fn get_stream<T: 'static, P: 'static>(
    pool: Arc<dyn DbConnectionPool<T, P> + Send + Sync>,
    sql: String,
    projected_schema: SchemaRef,
) -> Result<SendableRecordBatchStream>