Module create_source

Modules

• additional_column 🔒
• external_schema 🔒
  bind columns from external schema
• validate 🔒

Enums

• 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?

Constants

• UPSTREAM_SOURCE_KEY
• WEBHOOK_CONNECTOR

Functions

• 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_upsert 🔒
  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_string_from_options 🔒
• validate_compatibility