Skip to content


ProcessorContext<KForward, VForward> is an abstraction of contexts for Processors.

Contract (Subset)

Forwarding Record

void forward(
  Record<K, V> record)
void forward(
  Record<K, V> record,
  String childName)

Forwards a Record (to all or the specified child processor)

See ProcessorContextImpl

Scheduling Recurring Action

Cancellable schedule(
  Duration interval,
  PunctuationType type,
  Punctuator callback)

Schedules an recurring action (Punctuator) to be executed every interval ms

See ProcessorContextImpl


Back to top