pub type PbStreamSource = StreamSource;Aliased Type§
pub struct PbStreamSource {Show 13 fields
pub source_id: TypedId<8, 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>,
pub downstream_columns: Option<Columns>,
pub refresh_mode: Option<SourceRefreshMode>,
pub associated_table_id: Option<TypedId<0, u32>>,
pub iceberg_fetch_state_table: Option<StorageTableDesc>,
}Fields§
§source_id: TypedId<8, 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>§downstream_columns: Option<Columns>Downstream columns are used by list node to know which columns are needed.
refresh_mode: Option<SourceRefreshMode>§associated_table_id: Option<TypedId<0, u32>>§iceberg_fetch_state_table: Option<StorageTableDesc>List reads this dedicated Fetch queue at committed checkpoints to confirm phase completion.
The frontend sets only table_id to reference the paired Fetch state table; meta fills the
rest of the descriptor from that table’s catalog when building the actor graph.