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.

results matching ""

    No results matching ""