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_fields

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

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 🔒