datafusion_remote_table

Function build_and_transform_stream

Source 
pub async fn build_and_transform_stream(
    conn_args: ConnectionArgs,
    sql: String,
    projection: Option<Vec<usize>>,
    transform: Option<Arc<dyn Transform>>,
    schema: SchemaRef,
) -> Result<SendableRecordBatchStream>