PunctuationSchedule next(final long currTimestamp)PunctuationSchedule — Orderable ProcessorNodes At Timestamp
PunctuationSchedule is a Stamped with ProcessorNodes (as values).
In other words, PunctuationSchedule represents a ProcessorNode at a given timestamp and can be ordered in ascending order.
PunctuationSchedule is created when:
-
StreamTaskis requested to schedule -
PunctuationScheduleis requested for the next PunctuationSchedule
PunctuationSchedule takes the following when created:
next Method
next…FIXME
|
Note
|
next is used exclusively when PunctuationQueue is requested to mayPunctuate.
|