(
&self,
catalog: &Arc<dyn Catalog>,
names: &[ObjectName],
if_exists: bool,
)
| 789 | } |
| 790 | |
| 791 | async fn handle_drop_table( |
| 792 | &self, |
| 793 | catalog: &Arc<dyn Catalog>, |
| 794 | names: &[ObjectName], |
| 795 | if_exists: bool, |
| 796 | ) -> DFResult<DataFrame> { |
| 797 | for name in names { |
| 798 | let identifier = self.resolve_table_name(name)?; |
| 799 | catalog |
| 800 | .drop_table(&identifier, if_exists) |
| 801 | .await |
| 802 | .map_err(|e| DataFusionError::External(Box::new(e)))?; |
| 803 | } |
| 804 | ok_result(&self.ctx) |
| 805 | } |
| 806 | |
| 807 | async fn handle_alter_table( |
| 808 | &self, |
no test coverage detected