Categorygithub.com/numaproj/numaflowpkgudf
package
1.3.2
Repository: https://github.com/numaproj/numaflow.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
46
Dependents
1
Files
913 SLOC

# Packages

No description provided by the author
Package forward does the Read (fromBufferPartition) -> Process (map UDF) -> Forward (toBuffers) -> Ack (fromBufferPartition) loop.
Package rpc provides the interface to invoke UDFs (map, mapstream and reduce).

# Structs

No description provided by the author
No description provided by the author