PbSinkDesc

risingwave_pb::stream_plan

Type Alias PbSinkDesc 

Source 
pub type PbSinkDesc = SinkDesc;

Aliased Type§

pub struct PbSinkDesc {
Show 15 fields
    pub id: TypedId<8>,
    pub name: String,
    pub definition: String,
    pub plan_pk: Vec<ColumnOrder>,
    pub downstream_pk: Vec<u32>,
    pub distribution_key: Vec<u32>,
    pub properties: BTreeMap<String, String>,
    pub sink_type: i32,
    pub column_catalogs: Vec<ColumnCatalog>,
    pub db_name: String,
    pub sink_from_name: String,
    pub format_desc: Option<SinkFormatDesc>,
    pub target_table: Option<u32>,
    pub extra_partition_col_idx: Option<u64>,
    pub secret_refs: BTreeMap<String, SecretRef>,

}

Fields§

§id: TypedId<8>§name: String§definition: String§plan_pk: Vec<ColumnOrder>§downstream_pk: Vec<u32>§distribution_key: Vec<u32>§properties: BTreeMap<String, String>§sink_type: i32

to be deprecated

§column_catalogs: Vec<ColumnCatalog>§db_name: String§sink_from_name: String

If the sink is from table or mv, this is name of the table/mv. Otherwise it is the name of the sink itself.

§format_desc: Option<SinkFormatDesc>§target_table: Option<u32>§extra_partition_col_idx: Option<u64>§secret_refs: BTreeMap<String, SecretRef>