Function table_list_udtf

datafusion-examples/examples/udf/table_list_udtf.rs:38–53

()

// Defines a `table_list` UDTF that returns a list of tables within the provided session.

pub async fn table_list_udtf() -> Result<()> {
    let ctx = SessionContext::new();
    ctx.register_udtf(FUNCTION_NAME, Arc::new(TableListUdtf));

    // Register different kinds of tables.
    ctx.sql("create view v as select 1")
        .await?
        .collect()
        .await?;
    ctx.sql("create table t(a int)").await?.collect().await?;

    // Print results.
    ctx.sql("select * from table_list()").await?.show().await?;

    Ok(())
}

#[derive(Debug, Default)]
struct TableListUdtf;