risingwave_connector::sink::dynamodb

Function map_data

source
fn map_data(
    scalar_ref: Option<ScalarRefImpl<'_>>,
    data_type: &DataType,
) -> Result<AttributeValue>