Module create_table

Modules

col_id_gen 🔒

Structs

ColumnIdGenerator

Column ID generator for a new table or a new version of an existing table to alter.

CreateTableInfo

Arguments of the functions that generate a table plan, part 1.

CreateTableProps

Arguments of the functions that generate a table plan, part 2.

Enums

EitherOnConflict

On-conflict behavior either from user input or existing table catalog.

Functions

bind_cdc_table_schema 🔒

Derive schema for cdc table when create a new Table or alter an existing Table

bind_cdc_table_schema_externally 🔒

Derive schema for cdc table when create a new Table or alter an existing Table

bind_pk_and_row_id_on_relation

Binds primary keys defined in SQL.

bind_sql_column_constraints

Binds constraints that can be only specified in column definitions, currently generated columns and default columns.

bind_sql_columns

Binds the column schemas declared in CREATE statement into ColumnDesc. If a column is marked as primary key, its ColumnId is also returned. This primary key is not combined with table constraints yet.

bind_sql_pk_names

bind_table_constraints

Currently we only support Primary key table constraint, so just return pk names if it exists

bind_webhook_info 🔒

check_create_table_with_source

check_generated_column_constraints 🔒

create_iceberg_engine_table

derive_with_options_for_cdc_table 🔒

ensure_column_options_supported 🔒

gen_create_table_plan 🔒

gen_create_table_plan generates the plan for creating a table without an external stream source.

gen_create_table_plan_for_cdc_table 🔒

Generate stream plan for cdc table based on shared source. In replace workflow, the table_id is the id of the table to be replaced in create table workflow, the table_id is a placeholder will be filled in the Meta

gen_create_table_plan_with_source 🔒

gen_create_table_plan_with_source generates the plan for creating a table with an external stream source.

gen_create_table_plan_without_source 🔒

gen_table_plan_inner 🔒

gen_table_plan_with_source 🔒

generate_stream_graph_for_replace_table

generated_columns_check_for_cdc_table 🔒

get_source_and_resolved_table_name 🔒

handle_create_table

handle_create_table_plan 🔒

multiple_pk_definition_err 🔒

not_null_check_for_cdc_table 🔒

sanity_check_for_table_on_cdc_source 🔒