Module cdc_backfill 

Structs

CdcBackfillExecutor

NoSnapshotUpstreamHandler 🔒

PkCompareInfo 🔒

SnapshotCursor 🔒

Snapshot cursor together with the PK comparisons needed to filter upstream changes against it.

Enums

NoSnapshotUpstreamOutcome 🔒

Result of handling an upstream message while no snapshot is running.

Constants

METADATA_STATE_LEN 🔒

split_id, is_finished, row_count, cdc_offset all occupy 1 column each.

Functions

can_poll_upstream_while_creating_reader 🔒

get_cdc_json_parse_handling_from_properties 🔒

parse_debezium_chunk 🔒

transform_upstream