public interface Punctuator
ProcessorContext.schedule(long, PunctuationType, Punctuator)
void
punctuate(long timestamp)
void punctuate(long timestamp)