(&self, ctx: &SessionContext)
| 196 | } |
| 197 | |
| 198 | async fn register_tables(&self, ctx: &SessionContext) -> Result<()> { |
| 199 | for table in Self::TABLES { |
| 200 | let table_provider = self.get_table(ctx, table).await?; |
| 201 | ctx.register_table(table, table_provider)?; |
| 202 | } |
| 203 | Ok(()) |
| 204 | } |
| 205 | |
| 206 | async fn execute_query(&self, ctx: &SessionContext, sql: &str) -> Result<usize> { |
| 207 | let debug = self.common.debug; |
no test coverage detected