AcceptsLatestSeenOffsetHandler is a utility that can setLatestSeenOffsetOnSources on SparkDataStreams with support for AcceptsLatestSeenOffset.
setLatestSeenOffsetOnSources( offsets: Option[OffsetSeq], sources: Seq[SparkDataStream]): Unit
setLatestSeenOffsetOnSources is used when:
MicroBatchExecutionis requested to run an activated streaming query (and the currentBatchId has not been initialized yet)
ContinuousExecutionis requested to run a streaming query in continuous mode (and the currentBatchId has been initialized already)