See: Description
| Interface | Description |
|---|---|
| FixedKeyProcessor<KIn,VIn,VOut> |
A processor of key-value pair records where keys are immutable.
|
| FixedKeyProcessorContext<KForward,VForward> |
Processor context interface for
FixedKeyRecord. |
| FixedKeyProcessorSupplier<KIn,VIn,VOut> |
A processor supplier that can create one or more
FixedKeyProcessor instances. |
| ProcessingContext |
Processor context interface.
|
| Processor<KIn,VIn,KOut,VOut> |
A processor of key-value pair records.
|
| ProcessorContext<KForward,VForward> |
Processor context interface for
Record. |
| ProcessorSupplier<KIn,VIn,KOut,VOut> |
A processor supplier that can create one or more
Processor instances. |
| RecordMetadata |
| Class | Description |
|---|---|
| ContextualFixedKeyProcessor<KIn,VIn,VOut> |
An abstract implementation of
FixedKeyProcessor that manages the
FixedKeyProcessorContext instance and provides default no-op
implementation of FixedKeyProcessor.close(). |
| ContextualProcessor<KIn,VIn,KOut,VOut> |
An abstract implementation of
Processor that manages the ProcessorContext instance and provides default no-op
implementation of Processor.close(). |
| FixedKeyRecord<K,V> |
A data class representing an incoming record with fixed key for processing in a
FixedKeyProcessor
or a record to forward to downstream processors via FixedKeyProcessorContext. |
| InternalFixedKeyRecordFactory | |
| 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. |
Topology as the entry point for your program.