risingwave_connector::sink::decouple_checkpoint_log_sink

Function default_commit_checkpoint_interval

Source 
pub fn default_commit_checkpoint_interval() -> u64