spark-sql-streaming-StreamProgress.adoc

StreamProgress Custom Scala Map

StreamProgress is an extension of Scala’s scala.collection.immutable.Map with streaming sources as keys and their Offsets as values.