Skip to content

Processor

Processor<KIn, VIn, KOut, VOut> is an abstraction of processing nodes (in a stream processing topology).

Contract

close

void close()

Used when:

  • ProcessorNode is requested to close

init

void init(
  ProcessorContext<KOut, VOut> context)

Initializes this Processor (passing in a ProcessorContext)

Used when:

  • ProcessorNode is requested to init

process

void process(
  Record<KIn, VIn> record)

Used when:

  • ProcessorNode is requested to process

Implementations

  • ContextualProcessor
  • ForeachProcessor
Back to top