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
onMView
”.WriteHandle
writes its data into a table in a transactional way.
Enums§
- TxnState 🔒