risingwave_connector::sink::file_sink

Module batching_log_sink

Source

Structsยง

BatchingLogSinker
BatchingLogSinker is used for a commit-decoupled sink that supports cross-barrier batching. Currently, it is only used for file sinks, so it contains an OpenDalSinkWriter.