Module schema

Structs

• ResolvedAvroSchema
  Avro schema with Ref inlined. The newtype is used to indicate whether the schema is resolved.

Enums

• MapHandling
  How to convert the map type from the input encoding to RisingWave’s datatype.

Constants

• DBZ_VARIABLE_SCALE_DECIMAL_NAME 🔒
• DBZ_VARIABLE_SCALE_DECIMAL_NAMESPACE 🔒

Functions

• avro_field_to_column_desc 🔒
• avro_schema_to_column_descs
  This function expects resolved schema (no Ref). FIXME: require passing resolved schema here. TODO: change map_handling to some Config, and also unify debezium. TODO: use ColumnDesc in common instead of PB.
• avro_schema_to_struct_field_name 🔒
  The field name when converting Avro union type to RisingWave struct type.
• avro_type_mapping 🔒
  This function expects resolved schema (no Ref).
• supported_avro_to_json_type 🔒
  Check for super::avro_to_jsonb