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_pulsar_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 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_pulsar_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”.
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
fn is_batch_connector(&self) -> bool
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.