How it works
When you create an internal Iceberg table using a connection withhosted_catalog = true
, RisingWave automatically manages the Iceberg metadata within its own metastore.
- JDBC endpoint: The metastore exposes a JDBC endpoint that is compatible with the Iceberg JDBC catalog specification.
- External access: Because it uses a standard protocol, external query engines like Spark or Trino can connect to this endpoint to discover and query the Iceberg tables that RisingWave manages.
Create and test your table
To use the JDBC hosted catalog, you create aCONNECTION
with hosted_catalog = true
and then create an internal Iceberg table.
1. Create a connection
Define a connection that specifies your object storage backend. This example uses AWS S3.2. Set the default connection
Set the default connection for your session to simplify table creation.3. Create and query the table
Create an internal Iceberg table and write data to it.Complete Guide: Create and manage internal Iceberg tables
For a complete, step-by-step guide to creating and working with internal Iceberg tables, see this topic.