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,
    job_type: TableJobType,
    column_defs: Vec<ColumnDef>,
    constraints: Vec<TableConstraint>,
    table_name: ObjectName,
) -> Result<(), RwError>