Class MockProcessorContext.CapturedPunctuator
- java.lang.Object
-
- org.apache.kafka.streams.processor.MockProcessorContext.CapturedPunctuator
-
- Enclosing class:
- MockProcessorContext
public static class MockProcessorContext.CapturedPunctuator extends Object
MockProcessorContext.CapturedPunctuator
holds captured punctuators, along with their scheduling information.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
cancel()
boolean
cancelled()
long
getIntervalMs()
Punctuator
getPunctuator()
PunctuationType
getType()
-
-
-
Method Detail
-
getIntervalMs
public long getIntervalMs()
-
getType
public PunctuationType getType()
-
getPunctuator
public Punctuator getPunctuator()
-
cancel
public void cancel()
-
cancelled
public boolean cancelled()
-
-