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¶

• AbstractProcessorContext
• InternalProcessorContext