risingwave_connector::parser::unified::debezium

Function parse_transaction_meta

source 
pub fn parse_transaction_meta(
    accessor: &impl Access,
    connector_props: &ConnectorProperties,
) -> AccessResult<TransactionControl>