Trait WithPropertiesExt

source

pub trait WithPropertiesExt: Get + Sized {
    // Provided methods
    fn get_connector(&self) -> Option<String> { ... }
    fn is_kafka_connector(&self) -> bool { ... }
    fn is_mysql_cdc_connector(&self) -> bool { ... }
    fn is_cdc_connector(&self) -> bool { ... }
    fn is_shareable_cdc_connector(&self) -> bool { ... }
    fn is_shareable_only_cdc_connector(&self) -> bool { ... }
    fn enable_transaction_metadata(&self) -> bool { ... }
    fn is_shareable_non_cdc_connector(&self) -> bool { ... }
    fn is_iceberg_connector(&self) -> bool { ... }
    fn connector_need_pk(&self) -> bool { ... }
    fn is_new_fs_connector(&self) -> bool { ... }
}

Expand description

Utility methods for WITH properties (HashMap and BTreeMap).

Provided Methods§

source

fn is_shareable_cdc_connector(&self) -> bool

It is shared when CREATE SOURCE, and not shared when CREATE TABLE. So called “shareable”.

source

fn is_shareable_only_cdc_connector(&self) -> bool

Tables with MySQL and PostgreSQL connectors are maintained for backward compatibility. The newly added SQL Server CDC connector is only supported when created as shared.

source