risingwave_pb::stream_plan

Type Alias PbSourceBackfillNode

source
pub type PbSourceBackfillNode = SourceBackfillNode;
Expand description

Alias for SourceBackfillNode.

Aliased Type§

struct PbSourceBackfillNode {
    pub upstream_source_id: u32,
    pub row_id_index: Option<u32>,
    pub columns: Vec<ColumnCatalog>,
    pub info: Option<StreamSourceInfo>,
    pub source_name: String,
    pub with_properties: BTreeMap<String, String>,
    pub rate_limit: Option<u32>,
    pub state_table: Option<Table>,
    pub secret_refs: BTreeMap<String, SecretRef>,
}

Fields§

§upstream_source_id: u32§row_id_index: Option<u32>§columns: Vec<ColumnCatalog>§info: Option<StreamSourceInfo>§source_name: String§with_properties: BTreeMap<String, String>§rate_limit: Option<u32>

Backfill rate limit

§state_table: Option<Table>

| partition_id | backfill_progress |

§secret_refs: BTreeMap<String, SecretRef>