PbSinkParam

risingwave_pb::connector_service

Type Alias PbSinkParam 

Source 
pub type PbSinkParam = SinkParam;

Aliased Type§

pub struct PbSinkParam {
    pub sink_id: u32,
    pub properties: BTreeMap<String, String>,
    pub table_schema: Option<TableSchema>,
    pub sink_type: i32,
    pub db_name: String,
    pub sink_from_name: String,
    pub format_desc: Option<SinkFormatDesc>,
    pub sink_name: String,
}

Fields§

§sink_id: u32§properties: BTreeMap<String, String>§table_schema: Option<TableSchema>§sink_type: i32

to be deprecated

§db_name: String§sink_from_name: String§format_desc: Option<SinkFormatDesc>§sink_name: String