PunctuationQueue takes no arguments to be created.
PunctuationQueue is created along with a StreamTask.
PunctuationSchedule is added in schedule.
Cancellable schedule( PunctuationSchedule sched)
schedule is used when:
StreamTaskis requested to schedule a Punctuator
boolean mayPunctuate( long timestamp, PunctuationType type, ProcessorNodePunctuator processorNodePunctuator)
true when one or more punctuators were executed.
mayPunctuate goes over the
PunctuationSchedules in the PriorityQueue until there are no more
PunctuationSchedules or their timestamp is after the given
timestamp (in a
Only when the
PunctuationSchedule was not cancelled when the punctuator was executed,
mayPunctuate requests the
PunctuationSchedule for next PunctuationSchedule (for the given current
timestamp) and adds it to the PriorityQueue.
mayPunctuate takes a peek again at the (next) first
PunctuationSchedule in the PriorityQueue and starts (the loop) again.
mayPunctuate is used when: