pub trait SourceProperties:
TryFromBTreeMap
+ Clone
+ WithOptions
+ Debug {
type Split: SplitMetaData + TryFrom<SplitImpl, Error = ConnectorError> + Into<SplitImpl>;
type SplitEnumerator: SplitEnumerator<Properties = Self, Split = Self::Split>;
type SplitReader: SplitReader<Split = Self::Split, Properties = Self>;
const SOURCE_NAME: &'static str;
// Provided methods
fn init_from_pb_source(&mut self, _source: &PbSource) { ... }
fn init_from_pb_cdc_table_desc(&mut self, _table_desc: &ExternalTableDesc) { ... }
}Expand description
Represents WITH options for sources.
Each instance should add a #[derive(with_options::WithOptions)] marker.
Required Associated Constants§
const SOURCE_NAME: &'static str
Required Associated Types§
type Split: SplitMetaData + TryFrom<SplitImpl, Error = ConnectorError> + Into<SplitImpl>
type SplitEnumerator: SplitEnumerator<Properties = Self, Split = Self::Split>
type SplitReader: SplitReader<Split = Self::Split, Properties = Self>
Provided Methods§
Sourcefn init_from_pb_source(&mut self, _source: &PbSource)
fn init_from_pb_source(&mut self, _source: &PbSource)
Load additional info from PbSource. Currently only used by CDC.
Sourcefn init_from_pb_cdc_table_desc(&mut self, _table_desc: &ExternalTableDesc)
fn init_from_pb_cdc_table_desc(&mut self, _table_desc: &ExternalTableDesc)
Load additional info from ExternalTableDesc. Currently only used by CDC.
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.