OffsetSeq

OffsetSeq is…​FIXME

OffsetSeq is created when…​MEFIXME

toStreamProgress Method

toStreamProgress(sources: Seq[BaseStreamingSource]): StreamProgress

toStreamProgress then creates a new StreamProgress with the only sources that have the offsets defined.

toStreamProgress throws a AssertionError if the number of the input sources does not match the offsets.

Note

toStreamProgress is used when:

Creating OffsetSeq Instance

OffsetSeq takes the following when created:

results matching ""

    No results matching ""