risingwave_frontend::handler::create_table

Function create_iceberg_engine_table

Source 
pub async fn create_iceberg_engine_table(
    session: Arc<SessionImpl>,
    handler_args: HandlerArgs,
    source: Option<PbSource>,
    table: PbTable,
    graph: StreamFragmentGraph,
    table_name: ObjectName,
    job_type: PbTableJobType,
) -> Result<(), RwError>
Expand description

Iceberg table engine is composed of hummock table, iceberg sink and iceberg source.

  1. fetch iceberg engine options from the meta node. Or use iceberg engine connection provided by users.
  2. create a hummock table
  3. create an iceberg sink
  4. create an iceberg source

See https://github.com/risingwavelabs/risingwave/issues/21586 for an architecture diagram.