Module avro

Modules

• schema 🔒

Structs

• AvroAccess
• AvroParseOptions
  Options for parsing an AvroValue into Datum, with a root avro schema.
• AvroParseOptionsInner 🔒
  Options for parsing an AvroValue into Datum, with names resolved from root 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_schema_to_column_descs
  This function expects original schema (with Ref). 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 🔒