Struct DmlManager

pub struct DmlManager {
    pub table_readers: RwLock<HashMap<TableId, TableReader>>,
    txn_id_generator: TxnIdGenerator,
    dml_channel_initial_permits: usize,
}

DmlManager manages the communication between batch data manipulation and streaming processing. NOTE: TableDmlHandle is used here as an out-of-the-box solution. We should further optimize its implementation (e.g. directly expose a channel instead of offering a write_chunk interface).

Fields

table_readers: RwLock<HashMap<TableId, TableReader>>

txn_id_generator: TxnIdGenerator

dml_channel_initial_permits: usize

Implementations

impl DmlManager

pub fn new( worker_node_id: WorkerNodeId, dml_channel_initial_permits: usize, ) -> Self

pub fn for_test() -> Self

pub fn register_reader( &self, table_id: TableId, table_version_id: TableVersionId, column_descs: &[ColumnDesc], ) -> Result<TableDmlHandleRef>

Register a new DML reader for a table. If the reader for this version of the table already exists, returns a reference to the existing reader.

pub fn table_dml_handle( &self, table_id: TableId, table_version_id: TableVersionId, ) -> Result<TableDmlHandleRef>

pub fn clear(&self)

pub fn gen_txn_id(&self) -> TxnId

Trait Implementations

impl Debug for DmlManager

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

Formats the value using the given formatter.