Crate numaflow

Source
Expand description

A Rust SDK for Numaflow. The Rust SDK is experimental has only implemented the most important features. It will support all the core features eventually. It supports Map, Reduce, User Defined Sources, User Defined Source Transformer and User Defined Sinks.

Please note that the Rust SDK is experimental and will be refactored in the future to make it more idiomatic.

Modulesยง

batchmap
batchmap is for writing the batch map mode handlers.
error
error module
map
map is for writing the map handlers.
reduce
reduce is for writing the reduce handlers.
sideinput
building side input
sink
sink for writing user defined sinks.
source
source is for building custom user defined sources.
sourcetransform
sourcetransform for writing source data transformers.