org.apache.kafka.streams.processor

Interface Punctuator

public interface Punctuator

A functional interface used as an argument to ProcessorContext.schedule(Duration, PunctuationType, Punctuator).

See Also:

Cancellable

Method Summary

Modifier and Type	Method and Description
void	punctuate(long timestamp) Perform the scheduled periodic operation.

Method Detail

punctuate

void punctuate(long timestamp)

Perform the scheduled periodic operation.

Parameters:

timestamp - when the operation is being called, depending on PunctuationType