PunctuationSchedule¶

PunctuationSchedule is a Stamped of ProcessorNodes.

As a Stamped, PunctuationSchedule is also a Comparable (Java) and used in PunctuationQueues (which are PriorityQueues under the covers).

Creating Instance¶

PunctuationSchedule takes the following to be created:

• ProcessorNode
• Timestamp
• Interval
• Punctuator
• RepointableCancellable

PunctuationSchedule is created when:

• PunctuationSchedule is requested for the next PunctuationSchedule
• StreamTask is requested to schedule a punctuator

isCancelled¶

PunctuationSchedule defines isCancelled internal flag when created.

isCancelled is off (false) by default and can be turned on (true) in markCancelled.

markCancelled¶

void markCancelled()

markCancelled turns the isCancelled flag on.