Iceberg sql catalog implementation.
To build a sql catalog with configurations
Example
use HashMap;
use CatalogBuilder;
use ;
async
Iceberg sql catalog implementation.
To build a sql catalog with configurations
use std::collections::HashMap;
use iceberg::CatalogBuilder;
use iceberg_catalog_sql::{
SQL_CATALOG_PROP_BIND_STYLE, SQL_CATALOG_PROP_URI, SQL_CATALOG_PROP_WAREHOUSE,
SqlBindStyle, SqlCatalogBuilder,
};
#[tokio::main]
async fn main() {
let catalog = SqlCatalogBuilder::default()
.load(
"sql",
HashMap::from_iter([
(
SQL_CATALOG_PROP_URI.to_string(),
"http://localhost:8181".to_string(),
),
(
SQL_CATALOG_PROP_WAREHOUSE.to_string(),
"s3://warehouse".to_string(),
),
(
SQL_CATALOG_PROP_BIND_STYLE.to_string(),
SqlBindStyle::QMark.to_string(),
),
]),
)
.await
.unwrap();
}