Skip to main content

CdcSourceExternalTableIdentifier

risingwave_connector::source::cdc

Trait CdcSourceExternalTableIdentifier 

Source 
pub trait CdcSourceExternalTableIdentifier: CdcSourceTypeTrait {
    // Provided methods
    fn canonical_name(connect_properties: &BTreeMap<String, String>) -> String { ... }
    fn split_quoted_identifier(name: &str) -> Option<Vec<String>> { ... }
}
Expand description

Handles the identifiers of upstream objects of a CDC source connector, such as tables and columns: how the connector spells them, quotes them, and how Debezium names them.

Provided Methods§

Source

fn canonical_name(connect_properties: &BTreeMap<String, String>) -> String

Returns the canonical identifier of the external table that the connect properties of a CDC table point to: the part of the Debezium topic name of the table’s change events that the source reader keeps as _rw_table_name. A CDC table filters the change events of its source by this identifier, and its cdc_table_id is built from it.

Source

fn split_quoted_identifier(name: &str) -> Option<Vec<String>>

Splits a .-separated name, such as the one in the TABLE '...' clause of a CDC table, into its identifiers, following the connector’s quoting syntax. Returns None if the name is malformed.

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§