Structs§
- Table
DmlHandle TableDmlHandle
is a special internal source to handle table updates from user, including insert/delete/update statements via SQL interface.- Table
DmlHandle Core - Table
Stream Reader 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
onMView
”.- Write
Handle WriteHandle
writes its data into a table in a transactional way.
Enums§
- TxnState 🔒