(table_name: &str)
| 284 | } |
| 285 | |
| 286 | async fn create_provider(table_name: &str) -> PaimonTableProvider { |
| 287 | let catalog = create_catalog(); |
| 288 | let identifier = Identifier::new("default", table_name); |
| 289 | let table = catalog |
| 290 | .get_table(&identifier) |
| 291 | .await |
| 292 | .expect("Failed to get table"); |
| 293 | |
| 294 | PaimonTableProvider::try_new(table).expect("Failed to create table provider") |
| 295 | } |
| 296 | |
| 297 | async fn plan_partitions( |
| 298 | provider: &PaimonTableProvider, |