kafka-streams-PunctuationSchedule.adoc

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:

• StreamTask is requested to schedule

• PunctuationSchedule is requested for the next PunctuationSchedule

PunctuationSchedule takes the following when created:

• ProcessorNode

• Timestamp

• Interval

• Punctuator

• RepointableCancellable

next Method

PunctuationSchedule next(final long currTimestamp)

next…​FIXME

Note	next is used exclusively when PunctuationQueue is requested to mayPunctuate.