Page History

package org.apache.kafka.streams.processor.api;

public interface ProcessingContext {

	// New method allowing for anchored punctuation using cron expressions
	Cancellable schedule(final String cronExpression, final Punctuator callback);

	// Existing method
 	Cancellable schedule(final Duration interval, final long startTime, final PunctuationType type, final Punctuator callback);
}