Module avro

Modules

• schema 🔒

Structs

• AvroAccess
• AvroParseOptions
  Options for parsing an AvroValue into Datum, with an optional avro schema.
• 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.

Functions

• avro_decimal_to_rust_decimal 🔒
• avro_extract_field_schema
• avro_schema_skip_nullable_union
• 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_to_jsonb 🔒
• get_nullable_union_inner 🔒
  If the union schema is [null, T] or [T, null], returns Some(T); otherwise returns None.
• unix_epoch_days 🔒