Truncate the entire table (OVERWRITE with no filter, only deletes).
(&self)
| 280 | |
| 281 | /// Truncate the entire table (OVERWRITE with no filter, only deletes). |
| 282 | pub async fn truncate_table(&self) -> Result<()> { |
| 283 | self.try_commit(CommitEntriesPlan::Overwrite { |
| 284 | partition_filter: None, |
| 285 | new_entries: vec![], |
| 286 | new_index_entries: vec![], |
| 287 | }) |
| 288 | .await |
| 289 | } |
| 290 | |
| 291 | /// Try to commit with retries. |
| 292 | async fn try_commit(&self, plan: CommitEntriesPlan) -> Result<()> { |