risingwave_pb::catalog

Type Alias PbSink

source 
pub type PbSink = Sink;
Expand description

Alias for Sink.

Aliased Type§

struct PbSink {
Show 26 fields
    pub id: u32,
    pub schema_id: u32,
    pub database_id: u32,
    pub name: String,
    pub columns: Vec<ColumnCatalog>,
    pub plan_pk: Vec<ColumnOrder>,
    pub dependent_relations: Vec<u32>,
    pub distribution_key: Vec<i32>,
    pub downstream_pk: Vec<i32>,
    pub sink_type: i32,
    pub owner: u32,
    pub properties: BTreeMap<String, String>,
    pub definition: String,
    pub connection_id: Option<u32>,
    pub initialized_at_epoch: Option<u64>,
    pub created_at_epoch: Option<u64>,
    pub db_name: String,
    pub sink_from_name: String,
    pub stream_job_status: i32,
    pub format_desc: Option<SinkFormatDesc>,
    pub target_table: Option<u32>,
    pub initialized_at_cluster_version: Option<String>,
    pub created_at_cluster_version: Option<String>,
    pub create_type: i32,
    pub secret_refs: BTreeMap<String, SecretRef>,
    pub original_target_columns: Vec<ColumnCatalog>,

}

Fields§

§id: u32§schema_id: u32§database_id: u32§name: String§columns: Vec<ColumnCatalog>§plan_pk: Vec<ColumnOrder>

Primary key derived from the SQL by the frontend.

§dependent_relations: Vec<u32>
👎Deprecated
§distribution_key: Vec<i32>§downstream_pk: Vec<i32>

User-defined primary key indices for the upsert sink.

§sink_type: i32

to be deprecated

§owner: u32§properties: BTreeMap<String, String>§definition: String§connection_id: Option<u32>§initialized_at_epoch: Option<u64>§created_at_epoch: Option<u64>§db_name: String§sink_from_name: String§stream_job_status: i32§format_desc: Option<SinkFormatDesc>§target_table: Option<u32>

Target table id (only applicable for table sink)

§initialized_at_cluster_version: Option<String>

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

§created_at_cluster_version: Option<String>§create_type: i32

Whether it should use background ddl or block until backfill finishes.

§secret_refs: BTreeMap<String, SecretRef>

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

§original_target_columns: Vec<ColumnCatalog>

only for the sink whose target is a table. Columns of the target table when the sink is created. At this point all the default columns of the target table are all handled by the project operator in the sink plan.