advance

open suspend override fun advance(type: AggregateType, schema: String, cursor: String?, walked: Long, completed: Boolean): Boolean