numaflow
numaflow copied to clipboard
Streaming Transformer
### Numaflow Tasks
- [x] Update MonoVertex Source Transformer
- [x] Update Pipeline Source Transformer
### SDK Tasks
- [x] Golang
- [ ] Python
- [ ] Java
- [x] Rust