Package org.apache.kafka.streams.processor

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

Modifier and Type	Method	Description
void	cancel()
boolean	cancelled()
long	getIntervalMs()
Punctuator	getPunctuator()
PunctuationType	getType()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

getIntervalMs

public long getIntervalMs()

getType

public PunctuationType getType()

getPunctuator

public Punctuator getPunctuator()

cancel

public void cancel()

cancelled

public boolean cancelled()