Module decoder

risingwave_connector_codec

Module decoder

Expand description

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

Modules§

avro
json
protobuf
utils

Macros§

bail_parquet_parser: Constructs a AccessError::ParquetParser variant and bails out.
bail_uncategorized: Constructs a AccessError::Uncategorized variant and bails out.
parquet_parser: Constructs a AccessError::ParquetParser variant.
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