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.

results matching ""

    No results matching ""