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