Package org.apache.kafka.streams.processor.internals

Interface ProcessorNodePunctuator

All Known Implementing Classes:

StreamTask

public interface ProcessorNodePunctuator

Method Summary

Modifier and Type	Method	Description
void	punctuate(ProcessorNode<?,?> node, long timestamp, PunctuationType type, Punctuator punctuator)

Method Detail

punctuate

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