ProcessorNodePunctuator¶

ProcessorNodePunctuator is an abstraction of processor punctuators (that PunctuationQueues use to mayPunctuate).

Contract¶

punctuate¶

void punctuate(
  ProcessorNode<?, ?, ?, ?> node,
  long timestamp,
  PunctuationType type,
  Punctuator punctuator)

Used when:

• PunctuationQueue is requested to mayPunctuate

Implementations¶

• StreamTask