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