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