Skip to main content

Module batching_log_sink

risingwave_connector::sink

Module batching_log_sink 

Source

Structs§

BatchingLogSinker
Log sinker for sinks that batch rows across chunks: an offset is truncated only once a commit has made its rows visible downstream, preserving at-least-once delivery on restart.

Traits§

BatchingSinkWriter
A sink writer that buffers rows across chunks and commits them in batches, driven by BatchingLogSinker.