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 Details

    • getIntervalMs

      public long getIntervalMs()
    • getType

      public PunctuationType getType()
    • getPunctuator

      public Punctuator getPunctuator()
    • cancel

      public void cancel()
    • cancelled

      public boolean cancelled()