risingwave_dml

Module table

source

Structs§

  • TableDmlHandle is a special internal source to handle table updates from user, including insert/delete/update statements via SQL interface.
  • 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 writes its data into a table in a transactional way.

Enums§

Type Aliases§