risingwave_pb::stream_plan

Type Alias PbStreamCdcScanOptions

Source 
pub type PbStreamCdcScanOptions = StreamCdcScanOptions;

Aliased Type§

pub struct PbStreamCdcScanOptions {
    pub disable_backfill: bool,
    pub snapshot_barrier_interval: u32,
    pub snapshot_batch_size: u32,
    pub backfill_parallelism: u32,
    pub backfill_num_rows_per_split: u64,
    pub backfill_as_even_splits: bool,
    pub backfill_split_pk_column_index: u32,
}

Fields§

§disable_backfill: bool

Whether skip the backfill and only consume from upstream.

§snapshot_barrier_interval: u32§snapshot_batch_size: u32§backfill_parallelism: u32§backfill_num_rows_per_split: u64§backfill_as_even_splits: bool§backfill_split_pk_column_index: u32