Module cdc 

Re-exports

pub use enumerator::*;

pub use source::*;

Modules

enumerator

external

jni_source

mongodb

mysql

oracle

postgres

source

split

sql_server

Structs

CdcProperties

CdcScanOptions

CdcTableSnapshotSplitAssignmentWithGeneration

Mongodb

Mysql

Oracle

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

INITIAL_CDC_SPLIT_ASSIGNMENT_GENERATION_ID

INVALID_CDC_SPLIT_ASSIGNMENT_GENERATION_ID

MONGODB_CDC_CONNECTOR

MYSQL_CDC_CONNECTOR

ORACLE_CDC_CONNECTOR

POSTGRES_CDC_CONNECTOR

SQL_SERVER_CDC_CONNECTOR

Traits

CdcSourceDdlValidator

Checks the CREATE and ALTER statements of a CDC source connector.

CdcSourceRuntimeFlags

Behavior switches.

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_cdc_table_snapshot_split

check_alter_with_options_inner

check_common_with_options

Checks the WITH (...) options that every CDC source accepts, on both CREATE and ALTER.

check_format_encode_inner

check_include_column_inner

normalize_simple_postgres_quoted_table_name

table_schema_exclude_additional_columns

Type Aliases

MongodbCdcProperties

MysqlCdcProperties

OracleCdcProperties

PostgresCdcProperties

SqlServerCdcProperties