Type Alias PbSource

pub type PbSource = Source;

Alias for Source.

Aliased Type

struct PbSource {

    pub id: u32,
    pub schema_id: u32,
    pub database_id: u32,
    pub name: String,
    pub row_id_index: Option<u32>,
    pub columns: Vec<ColumnCatalog>,
    pub pk_column_ids: Vec<i32>,
    pub with_properties: BTreeMap<String, String>,
    pub owner: u32,
    pub info: Option<StreamSourceInfo>,
    pub watermark_descs: Vec<WatermarkDesc>,
    pub definition: String,
    pub connection_id: Option<u32>,
    pub initialized_at_epoch: Option<u64>,
    pub created_at_epoch: Option<u64>,
    pub initialized_at_cluster_version: Option<String>,
    pub created_at_cluster_version: Option<String>,
    pub secret_refs: BTreeMap<String, SecretRef>,
    pub version: u64,
    pub rate_limit: Option<u32>,
    pub optional_associated_table_id: Option<OptionalAssociatedTableId>,
}

Fields

id: u32

For shared source, this is the same as the job id. For non-shared source and table with connector, this is a different oid.

schema_id: u32

database_id: u32

name: String

row_id_index: Option<u32>

The column index of row ID. If the primary key is specified by the user, this will be None.

columns: Vec<ColumnCatalog>

Columns of the source.

pk_column_ids: Vec<i32>

Column id of the primary key specified by the user. If the user does not specify a primary key, the vector will be empty.

with_properties: BTreeMap<String, String>

Properties specified by the user in WITH clause.

owner: u32

info: Option<StreamSourceInfo>

watermark_descs: Vec<WatermarkDesc>

Define watermarks on the source. The repeated is just for forward compatibility, currently, only one watermark on the source

definition: String

connection_id: Option<u32>

initialized_at_epoch: Option<u64>

created_at_epoch: Option<u64>

initialized_at_cluster_version: Option<String>

Cluster version (tracked by git commit) when initialized/created

created_at_cluster_version: Option<String>

secret_refs: BTreeMap<String, SecretRef>

Handle the source relies on any sceret. The key is the propertity name and the value is the secret id. Used for secret connect options.

version: u64

Per-source catalog version, used by schema change.

rate_limit: Option<u32>

optional_associated_table_id: Option<OptionalAssociatedTableId>

Indicate whether this source is created by table.