Struct CdcTableDesc

pub struct CdcTableDesc {
    pub table_id: TableId,
    pub source_id: TableId,
    pub external_table_name: String,
    pub pk: Vec<ColumnOrder>,
    pub columns: Vec<ColumnDesc>,
    pub stream_key: Vec<usize>,
    pub connect_properties: BTreeMap<String, String>,
    pub secret_refs: BTreeMap<String, PbSecretRef>,
}

Necessary information for compute node to access data in the external database. Compute node will use this information to connect to the external database and scan the table.

Fields

table_id: TableId

Id of the table in RW

source_id: TableId

Id of the upstream source in sharing cdc mode

external_table_name: String

The full name of the table in external database, e.g. database_name.table_name in MySQL and schema_name.table_name in the Postgres.

pk: Vec<ColumnOrder>

The key used to sort in storage.

columns: Vec<ColumnDesc>

All columns in the table, noticed it is NOT sorted by columnId in the vec.

stream_key: Vec<usize>

Column indices for primary keys.

connect_properties: BTreeMap<String, String>

properties will be passed into the StreamScanNode

secret_refs: BTreeMap<String, PbSecretRef>

Secret refs

Implementations

impl CdcTableDesc

pub fn order_column_indices(&self) -> Vec<usize>

pub fn order_column_ids(&self) -> Vec<ColumnId>

pub fn to_protobuf(&self) -> ExternalTableDesc

pub fn get_id_to_op_idx_mapping(&self) -> HashMap<ColumnId, usize>

Helper function to create a mapping from column id to column index

Trait Implementations

impl Clone for CdcTableDesc

fn clone(&self) -> CdcTableDesc

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CdcTableDesc

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for CdcTableDesc

fn default() -> CdcTableDesc

Returns the “default value” for a type.

impl Hash for CdcTableDesc

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for CdcTableDesc

fn eq(&self, other: &CdcTableDesc) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for CdcTableDesc

impl StructuralPartialEq for CdcTableDesc