try_base64_decode_decimal

risingwave_connector::parser::unified::json

Function try_base64_decode_decimal 

Source 
fn try_base64_decode_decimal(
    str_val: &str,
    bigint_unsigned_handling: BigintUnsignedHandlingMode,
    create_error: impl Fn() -> AccessError,
) -> Result<Decimal, AccessError>
Expand description

Try to decode a base64-encoded decimal string for unsigned bigint handling in Precise mode.

This is used when processing CDC data from upstream systems with unsigned bigint (e.g., MySQL CDC). When users configure debezium.bigint.unsigned.handling.mode='precise', Debezium converts unsigned bigint to base64-encoded decimal.

Reference: https://debezium.io/documentation/reference/stable/connectors/mysql.html#mysql-property-bigint-unsigned-handling-mode.