updateStats

fun updateStats(committedRecords: Long, bytes: Long, rejectedRecords: Long = 0)