Structs§
DmlManager
manages the communication between batch data manipulation and streaming processing. NOTE:TableDmlHandle
is used here as an out-of-the-box solution. We should further optimize its implementation (e.g. directly expose a channel instead of offering awrite_chunk
interface).