Struct PaimonSqlHandler 

pub struct PaimonSqlHandler { /* private fields */ }

Wraps a SessionContext and a Paimon Catalog to handle DDL statements that DataFusion does not natively support (e.g. ALTER TABLE).

For all other SQL, it delegates to the inner SessionContext.

Example

let handler = PaimonSqlHandler::new(ctx, catalog);
let df = handler.sql("ALTER TABLE paimon.db.t ADD COLUMN age INT").await?;

Implementations

impl PaimonSqlHandler

pub fn new( ctx: SessionContext, catalog: Arc<dyn Catalog>, catalog_name: impl Into<String>, ) -> Self

pub fn ctx(&self) -> &SessionContext

Returns a reference to the inner SessionContext.

pub async fn sql(&self, sql: &str) -> DFResult<DataFrame>

Execute a SQL statement. ALTER TABLE is handled by Paimon directly; everything else is delegated to DataFusion.