Struct TableDmlHandle

pub struct TableDmlHandle {
    pub core: RwLock<TableDmlHandleCore>,
    pub column_descs: Vec<ColumnDesc>,
    dml_channel_initial_permits: usize,
}

TableDmlHandle is a special internal source to handle table updates from user, including insert/delete/update statements via SQL interface.

Changed rows will be send to the associated “materialize” streaming task, then be written to the state store. Therefore, TableDmlHandle can be simply be treated as a channel without side effects.

Fields

core: RwLock<TableDmlHandleCore>

column_descs: Vec<ColumnDesc>

All columns in this table.

dml_channel_initial_permits: usize

The initial permits of the channel between each TableDmlHandle and the dml executors.

Implementations

impl TableDmlHandle

pub fn new( column_descs: Vec<ColumnDesc>, dml_channel_initial_permits: usize, ) -> Self

pub fn stream_reader(&self) -> TableStreamReader

pub fn write_handle( &self, session_id: u32, txn_id: TxnId, ) -> Result<WriteHandle>

pub fn column_descs(&self) -> &[ColumnDesc]

Get the reference of all columns in this table.

pub fn check_chunk_schema(&self, chunk: &StreamChunk)

Trait Implementations

impl Debug for TableDmlHandle

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

Formats the value using the given formatter.