| Interface | Description |
|---|---|
| Processor<KIn,VIn,KOut,VOut> |
A processor of key-value pair records.
|
| ProcessorContext<KForward,VForward> |
Processor context interface.
|
| ProcessorSupplier<KIn,VIn,KOut,VOut> |
A processor supplier that can create one or more
Processor instances. |
| RecordMetadata |
| Class | Description |
|---|---|
| MockProcessorContext<KForward,VForward> |
MockProcessorContext is a mock of ProcessorContext for users to test their Processor,
Transformer, and ValueTransformer implementations. |
| MockProcessorContext.CapturedForward<K,V> | |
| MockProcessorContext.CapturedPunctuator |
MockProcessorContext.CapturedPunctuator holds captured punctuators, along with their scheduling information. |
| Record<K,V> |
A data class representing an incoming record for processing in a
Processor
or a record to forward to downstream processors via ProcessorContext. |