Skip to content

Latest commit

 

History

History
19 lines (15 loc) · 994 Bytes

kafka-streams-internals-ProcessorNodePunctuator.adoc

File metadata and controls

19 lines (15 loc) · 994 Bytes

ProcessorNodePunctuator Contract

ProcessorNodePunctuator is the abstraction of processor node punctuators that can punctuate a processor, i.e. execute scheduled periodic actions.

void punctuate(
  ProcessorNode node,
  long streamTime,
  PunctuationType type,
  Punctuator punctuator)

punctuate is used exclusively when PunctuationQueue is requested to attempt to punctuate (for StreamTask that attempts to punctuate by stream and system time).

Note
 StreamTask is the default and only known implementation of the ProcessorNodePunctuator Contract in Kafka Streams.