risingwave_connector::source::cdc

Module split

Source

Macros§

dispatch_cdc_split 🔒
dispatch_cdc_split_inner 🔒

Structs§

CdcSplitBase
The base states of a CDC split, which will be persisted to checkpoint. CDC source only has single split, so we use the source_id to identify the split.
DebeziumCdcSplit
We use this struct to wrap the specific split, which act as an interface to other modules
MongoDbCdcSplit
MySqlCdcSplit
PostgresCdcSplit
SqlServerCdcSplit

Traits§

CdcSplitTrait 🔒