MockProcessorContext.CapturedPunctuator (kafka 3.0.2 API)

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
clone, equals, finalize, 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()