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_schema_to_fields

This function expects original schema (with Ref). TODO: change map_handling to some Config, and also unify debezium.

avro_schema_to_struct_field_name 🔒

The field name when converting Avro union type to RisingWave struct type.

avro_type_mapping 🔒

This function expects original schema (with Ref).

supported_avro_to_json_type 🔒

Check for super::avro_to_jsonb