Module create_source

Modules§

CreateSourceType
SqlColumnStrategy: When the schema can be inferred from external system (like schema registry), how to handle the regular columns (i.e., non-generated) defined in SQL?

bind_all_columns 🔒: Bind columns from both source and sql defined.
bind_columns_from_source: Resolves the schema of the source from external schema file. See https://www.risingwave.dev/docs/current/sql-create-source for more information.
bind_connector_props
bind_create_source_or_table_with_connector
bind_source_pk 🔒: Bind column from source. Add key column to table columns if necessary. Return pk_names.
bind_source_watermark 🔒
check_format_encode 🔒: Performs early stage checking in frontend to see if the schema of the given columns is compatible with the connector extracted from the properties.
consume_aws_config_from_options 🔒
consume_string_from_options 🔒
generate_stream_graph_for_source 🔒
get_schema_location
handle_addition_columns: add connector-spec columns to the end of column catalog
handle_create_source
hint_format_encode 🔒: TODO: perhaps put the hint in notice is better. The error message format might be not that reliable.
non_generated_sql_columns 🔒
schema_has_schema_registry
try_consume_schema_registry_config_from_options 🔒
try_consume_string_from_options 🔒
validate_compatibility