Class PunctuationQueue
- java.lang.Object
-
- org.apache.kafka.streams.processor.internals.PunctuationQueue
-
public class PunctuationQueue extends Object
-
-
Constructor Summary
Constructors Constructor Description PunctuationQueue()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
Cancellable
schedule(PunctuationSchedule sched)
-
-
-
Method Detail
-
schedule
public Cancellable schedule(PunctuationSchedule sched)
-
close
public void close()
-
-