PbStreamFsFetch

risingwave_pb::stream_plan

Type Alias PbStreamFsFetch 

Source 
pub type PbStreamFsFetch = StreamFsFetch;

Aliased Type§

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

Fields§

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

Source rate limit

§secret_refs: BTreeMap<String, SecretRef>