diff --git a/crates/integrations/datafusion/public-api.txt b/crates/integrations/datafusion/public-api.txt index 5fcb4e85d3..caa2cc27e0 100644 --- a/crates/integrations/datafusion/public-api.txt +++ b/crates/integrations/datafusion/public-api.txt @@ -71,6 +71,9 @@ pub fn iceberg_datafusion::IcebergStaticTableProvider::schema(&self) -> arrow_sc pub fn iceberg_datafusion::IcebergStaticTableProvider::supports_filters_pushdown(&self, filters: &[&datafusion_expr::expr::Expr]) -> datafusion_common::error::Result> pub fn iceberg_datafusion::IcebergStaticTableProvider::table_type(&self) -> datafusion_expr::table_source::TableType pub struct iceberg_datafusion::table::IcebergTableProvider +impl iceberg_datafusion::IcebergTableProvider +pub async fn iceberg_datafusion::IcebergTableProvider::metadata_table(&self, type: iceberg::inspect::metadata_table::MetadataTableType) -> iceberg::error::Result +pub async fn iceberg_datafusion::IcebergTableProvider::try_new(catalog: alloc::sync::Arc, namespace: iceberg::catalog::NamespaceIdent, name: impl core::convert::Into) -> iceberg::error::Result impl core::clone::Clone for iceberg_datafusion::IcebergTableProvider pub fn iceberg_datafusion::IcebergTableProvider::clone(&self) -> iceberg_datafusion::IcebergTableProvider impl core::fmt::Debug for iceberg_datafusion::IcebergTableProvider @@ -115,6 +118,9 @@ pub fn iceberg_datafusion::IcebergStaticTableProvider::schema(&self) -> arrow_sc pub fn iceberg_datafusion::IcebergStaticTableProvider::supports_filters_pushdown(&self, filters: &[&datafusion_expr::expr::Expr]) -> datafusion_common::error::Result> pub fn iceberg_datafusion::IcebergStaticTableProvider::table_type(&self) -> datafusion_expr::table_source::TableType pub struct iceberg_datafusion::IcebergTableProvider +impl iceberg_datafusion::IcebergTableProvider +pub async fn iceberg_datafusion::IcebergTableProvider::metadata_table(&self, type: iceberg::inspect::metadata_table::MetadataTableType) -> iceberg::error::Result +pub async fn iceberg_datafusion::IcebergTableProvider::try_new(catalog: alloc::sync::Arc, namespace: iceberg::catalog::NamespaceIdent, name: impl core::convert::Into) -> iceberg::error::Result impl core::clone::Clone for iceberg_datafusion::IcebergTableProvider pub fn iceberg_datafusion::IcebergTableProvider::clone(&self) -> iceberg_datafusion::IcebergTableProvider impl core::fmt::Debug for iceberg_datafusion::IcebergTableProvider diff --git a/crates/integrations/datafusion/src/table/mod.rs b/crates/integrations/datafusion/src/table/mod.rs index 9de7bcb9c2..4e71dc3efb 100644 --- a/crates/integrations/datafusion/src/table/mod.rs +++ b/crates/integrations/datafusion/src/table/mod.rs @@ -79,7 +79,7 @@ impl IcebergTableProvider { /// /// Loads the table once to get the initial schema, then stores the catalog /// reference for future metadata refreshes on each operation. - pub(crate) async fn try_new( + pub async fn try_new( catalog: Arc, namespace: NamespaceIdent, name: impl Into, @@ -97,7 +97,7 @@ impl IcebergTableProvider { }) } - pub(crate) async fn metadata_table( + pub async fn metadata_table( &self, r#type: MetadataTableType, ) -> Result {