Module create_source

Constants

• UPSTREAM_SOURCE_KEY

Statics

• CONNECTORS_COMPATIBLE_FORMATS 🔒

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_columns_from_source_for_cdc 🔒
• 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_additional_column_compatibility 🔒
• check_and_add_timestamp_column 🔒
• 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.
• check_iceberg_source
• check_nexmark_schema 🔒
• consume_aws_config_from_options 🔒
• consume_string_from_options 🔒
• debezium_cdc_source_schema
  Note: these columns are added in SourceStreamChunkRowWriter::do_action. May also look for the usage of SourceColumnType.
• extract_avro_table_schema 🔒
  Map an Avro schema to a relational schema.
• extract_debezium_avro_table_pk_columns 🔒
• extract_iceberg_columns
• extract_json_table_schema 🔒
  Map a JSON schema to a relational schema
• extract_protobuf_table_schema 🔒
  Map a protobuf schema to a relational schema.
• format_to_prost 🔒
• get_json_schema_location
• get_name_strategy_or_default 🔒
• 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.
• json_schema_infer_use_schema_registry 🔒
• non_generated_sql_columns 🔒
• row_encode_to_prost 🔒
• try_consume_string_from_options 🔒
• validate_compatibility
• validate_license