pub trait WithPropertiesExt:
Get
+ GetKeyIter
+ Sized {
Show 15 methods
// Provided methods
fn get_connector(&self) -> Option<String> { ... }
fn is_kafka_connector(&self) -> bool { ... }
fn is_mysql_cdc_connector(&self) -> bool { ... }
fn get_sync_call_timeout(&self) -> Option<Duration> { ... }
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_legacy_fs_connector(&self) -> bool { ... }
fn is_new_fs_connector(&self) -> bool { ... }
fn is_batch_connector(&self) -> bool { ... }
fn requires_singleton(&self) -> bool { ... }
}Expand description
Utility methods for WITH properties (HashMap and BTreeMap).
Provided Methods§
fn get_connector(&self) -> Option<String>
fn is_kafka_connector(&self) -> bool
fn is_mysql_cdc_connector(&self) -> bool
fn get_sync_call_timeout(&self) -> Option<Duration>
fn is_cdc_connector(&self) -> bool
It is shared when CREATE SOURCE, and not shared when CREATE TABLE. So called “shareable”.
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.
fn enable_transaction_metadata(&self) -> bool
fn is_iceberg_connector(&self) -> bool
fn connector_need_pk(&self) -> bool
fn is_legacy_fs_connector(&self) -> bool
fn is_new_fs_connector(&self) -> bool
Sourcefn is_batch_connector(&self) -> bool
fn is_batch_connector(&self) -> bool
See crate::source::batch::BatchSourceSplit for more details.
fn requires_singleton(&self) -> bool
Dyn Compatibility§
This trait is not dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.