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ยง
- accumulator
- accumulator is for implementing accumulator handlers.
- batchmap
- batchmap is for writing the map in batch mode handlers.
- error
- Error handling types and utilities
- map
- Map functionality for writing the map handlers.
- mapstream
- mapstream is for writing the map in stream mode handlers.
- proto
- Generated protobuf modules Generated protobuf modules
- reduce
- Reduce functionality for writing the reduce handlers.
- reducestream
- Reduce stream functionality for writing streaming reduce handlers.
- serving_
store - session_
reduce - session_reduce is for implementing session reduce handlers.
- shared
- Shared utilities, traits, and common functionality Shared utilities, and common functionality
- sideinput
- Side input functionality for building side input handlers.
- sink
- Sink functionality for writing user defined sinks.
- source
- source is for building custom user defined sources.
- sourcetransform
- Source transform functionality for writing source data transformers.