risingwave_connector::source

Module cdc

Source

Re-exports§

pub use enumerator::*;
pub use source::*;

Modules§

enumerator
external
jni_source
source
split

Structs§

CdcProperties
CdcScanOptions
CdcTableSnapshotSplitAssignmentWithGeneration
Citus
Mongodb
Mysql
Postgres
SqlServer

Enums§

CdcSourceType

Constants§

CDC_BACKFILL_AS_EVEN_SPLITS
CDC_BACKFILL_ENABLE_KEY
CDC_BACKFILL_MAX_PARALLELISM
CDC_BACKFILL_NUM_ROWS_PER_SPLIT
CDC_BACKFILL_PARALLELISM
CDC_BACKFILL_SNAPSHOT_BATCH_SIZE_KEY
CDC_BACKFILL_SNAPSHOT_INTERVAL_KEY
CDC_BACKFILL_SPLIT_PK_COLUMN_INDEX
CDC_CONNECTOR_NAME_SUFFIX
CDC_MONGODB_STRONG_SCHEMA_KEY
CDC_SHARING_MODE_KEY
CDC_SNAPSHOT_BACKFILL
CDC_SNAPSHOT_MODE_KEY
CDC_TRANSACTIONAL_KEY
CDC_WAIT_FOR_STREAMING_START_TIMEOUT
CITUS_CDC_CONNECTOR
INITIAL_CDC_SPLIT_ASSIGNMENT_GENERATION_ID
INVALID_CDC_SPLIT_ASSIGNMENT_GENERATION_ID
MONGODB_CDC_CONNECTOR
MYSQL_CDC_CONNECTOR
POSTGRES_CDC_CONNECTOR
SQL_SERVER_CDC_CONNECTOR

Traits§

CdcSourceTypeTrait

Functions§

build_actor_cdc_table_snapshot_splits_with_generation
build_cdc_table_id
Build a unique CDC table identifier from a source ID and external table name
build_pb_actor_cdc_table_snapshot_splits
build_pb_actor_cdc_table_snapshot_splits_with_generation
table_schema_exclude_additional_columns

Type Aliases§

CdcTableSnapshotSplitAssignment
CitusCdcProperties
MongodbCdcProperties
MysqlCdcProperties
PostgresCdcProperties
SqlServerCdcProperties