risingwave_connector_codec

Module decoder

Source
Expand description

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

Modules§

avro
json
protobuf
utils

Macros§

bail_uncategorized
Constructs a AccessError::Uncategorized variant and bails out.
uncategorized
Constructs a AccessError::Uncategorized variant.

Enums§

AccessError

Traits§

Access
Access to a field in the data structure. Created by AccessBuilder.
AccessExt

Type Aliases§

AccessResult