Module create_table

Structs

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

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
• check_create_table_with_source
• check_generated_column_constraints 🔒
• 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
• get_source_and_resolved_table_name 🔒
• handle_create_table
• handle_create_table_plan 🔒
• multiple_pk_definition_err 🔒
• sanity_check_for_cdc_table 🔒