Crate risingwave_dml 

Modules

dml_manager

error

table 🔒

txn_channel 🔒

Structs

TableDmlHandle

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

TableDmlHandleCore

TableStreamReader

TableStreamReader reads changes from a certain table continuously. This struct should be only used for associated materialize task, thus the reader should be created only once. Further streaming task relying on this table source should follow the structure of “MView on MView”.

WriteHandle

WriteHandle writes its data into a table in a transactional way.

Type Aliases

TableDmlHandleRef