Skip to content

ProcessorContext

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

Implementations

Back to top