public interface PunctuatorProcessorContext.schedule(Duration, PunctuationType, Punctuator).Cancellable| Modifier and Type | Method and Description |
|---|---|
void | punctuate(long timestamp)Perform the scheduled periodic operation. |
void punctuate(long timestamp)
If this method accesses ProcessorContext or ProcessorContext, record metadata like topic, partition, and offset or RecordMetadata won't be available.
Furthermore, for any record that is sent downstream via ProcessorContext.forward(Object, Object) or ProcessorContext.forward(Record), there won't be any record metadata. If ProcessorContext.forward(Object, Object) is used, it's also not possible to set records headers.
timestamp - when the operation is being called, depending on PunctuationType