Type Alias PbStreamCdcScanNode 

pub type PbStreamCdcScanNode = StreamCdcScanNode;

Aliased Type

pub struct PbStreamCdcScanNode {
    pub table_id: TypedId<1>,
    pub upstream_column_ids: Vec<i32>,
    pub output_indices: Vec<u32>,
    pub state_table: Option<Table>,
    pub cdc_table_desc: Option<ExternalTableDesc>,
    pub rate_limit: Option<u32>,
    pub disable_backfill: bool,
    pub options: Option<StreamCdcScanOptions>,
}

Fields

table_id: TypedId<1>

upstream_column_ids: Vec<i32>

The columns from the upstream table that’ll be internally required by this stream scan node. Contains Primary Keys and Output columns.

output_indices: Vec<u32>

Strips the primary key columns if they’re unnecessary.

state_table: Option<Table>

The state table used by CdcBackfill operator for persisting internal state

cdc_table_desc: Option<ExternalTableDesc>

The external table that will be backfilled for CDC.

rate_limit: Option<u32>

The backfill rate limit for the stream cdc scan node.

disable_backfill: bool

Whether skip the backfill and only consume from upstream. keep it for backward compatibility, new stream plan will use options.disable_backfill

options: Option<StreamCdcScanOptions>