Execute operation on specific data source catalog This is the main entry point for all data source catalog operations. The operation is routed to the appropriate data source catalog provider based on the catalog name. # Arguments `catalog_name` - Name of the data source catalog to execute the operation on `operation` - The data source catalog operation to execute Execute a query operation with
(
&mut self,
catalog_name: &str,
query_type: QueryType,
params: serde_json::Value,
)
| 271 | /// * `Ok(CatalogResponse)` with query results |
| 272 | /// * `Err(CatalogError)` if operation fails |
| 273 | pub fn query( |
| 274 | &mut self, |
| 275 | catalog_name: &str, |
| 276 | query_type: QueryType, |
| 277 | params: serde_json::Value, |
| 278 | ) -> CatalogResult<CatalogResponse> { |
| 279 | self.execute(catalog_name, CatalogOperation::Query { query_type, params }) |
| 280 | } |
| 281 | |
| 282 | /// Create an entity with convenience method |
| 283 | /// |