Class MockProcessorContext.CapturedPunctuator
- java.lang.Object
-
- org.apache.kafka.streams.processor.api.MockProcessorContext.CapturedPunctuator
-
- Enclosing class:
- MockProcessorContext<KForward,VForward>
public static final 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()
Duration
getInterval()
Punctuator
getPunctuator()
PunctuationType
getType()
-
-
-
Method Detail
-
getInterval
public Duration getInterval()
-
getType
public PunctuationType getType()
-
getPunctuator
public Punctuator getPunctuator()
-
cancel
public void cancel()
-
cancelled
public boolean cancelled()
-
-