spark技术分享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.
StreamProgress is created when…MEFIXME
StreamProgress takes a Map of Offsets per BaseStreamingSource when created.
