Skip to content

Commit 9a35412

Browse files
committed
Add datafusion insert into slt
1 parent db52d72 commit 9a35412

File tree

1 file changed

+0
-19
lines changed
  • crates/integrations/datafusion/src/table

1 file changed

+0
-19
lines changed

crates/integrations/datafusion/src/table/mod.rs

Lines changed: 0 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -104,25 +104,6 @@ impl IcebergTableProvider {
104104
let table = self.catalog.load_table(&self.table_ident).await?;
105105
Ok(IcebergMetadataTableProvider { table, r#type })
106106
}
107-
108-
/// Reload the table from the catalog if needed to get fresh metadata.
109-
/// This is useful after INSERT operations that modify the table.
110-
pub(crate) async fn reload_if_needed(&self) -> Result<Self> {
111-
if let Some(catalog) = &self.catalog {
112-
// Reload the table from the catalog to get the latest metadata
113-
let table = catalog.load_table(self.table.identifier()).await?;
114-
let schema = Arc::new(schema_to_arrow_schema(table.metadata().current_schema())?);
115-
Ok(IcebergTableProvider {
116-
table,
117-
snapshot_id: self.snapshot_id,
118-
schema,
119-
catalog: self.catalog.clone(),
120-
})
121-
} else {
122-
// If no catalog is available, return a clone of self
123-
Ok(self.clone())
124-
}
125-
}
126107
}
127108

128109
#[async_trait]

0 commit comments

Comments
 (0)