Crate risingwave_connector_codec

Encoding and decoding between external data formats and RisingWave datum (i.e., type mappings).

Modules

• common
• decoder
  Converts JSON/AVRO/Protobuf data to RisingWave datum. The core API is decoder::Access.

Macros

• __thiserror_ext_macro__access_error__uncategorized
  Constructs a AccessError::Uncategorized variant.
• __thiserror_ext_macro__access_error__uncategorized__bail
  Constructs a AccessError::Uncategorized variant and bails out.

Structs

• ColumnDesc
• JsonSchema

Enums

• AvroSchema
  Represents any valid Avro schema More information about Avro schemas can be found in the Avro Specification
• AvroValue
  A valid Avro value.
• AvroValueKind
  Auto-generated discriminant enum variants