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 Details

    • getInterval

      public Duration getInterval()
    • getType

      public PunctuationType getType()
    • getPunctuator

      public Punctuator getPunctuator()
    • cancel

      public void cancel()
    • cancelled

      public boolean cancelled()