(catalog: Arc<FileSystemCatalog>)
| 36 | } |
| 37 | |
| 38 | pub async fn create_sql_context(catalog: Arc<FileSystemCatalog>) -> SQLContext { |
| 39 | let mut ctx = SQLContext::new(); |
| 40 | ctx.register_catalog("paimon", catalog).await.unwrap(); |
| 41 | ctx |
| 42 | } |
| 43 | |
| 44 | #[allow(dead_code)] |
| 45 | pub async fn setup_sql_context() -> (TempDir, SQLContext) { |
no test coverage detected