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.