API Reference¶
This section provides detailed API documentation for all pynumaflow modules.
Modules¶
| Module | Description |
|---|---|
| Sourcer | User Defined Source for custom data sources |
| Source Transformer | Transform data at ingestion |
| Mapper | Map UDF for transforming messages one at a time |
| Map Streamer | MapStream UDF for streaming results as they're produced |
| Batch Mapper | BatchMap UDF for processing messages in batches |
| Sinker | User Defined Sink for custom data destinations |
| Reducer | Reduce UDF for aggregating messages by key and time window |
| Reduce Streamer | Stream reduce results incrementally |
| Accumulator | Accumulate and process data with state |
| Side Input | Inject external data into UDFs |