spark技术分享OffsetSeq
OffsetSeq is…FIXME
OffsetSeq is created when…MEFIXME
toStreamProgress Method
|
1 2 3 4 5 |
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
|
|
Creating OffsetSeq Instance
OffsetSeq takes the following when created:
-
Collection of Offsets
-
OffsetSeqMetadata (default:
None)
