feat: implement reduce stream sdk - Githubissues

numaproj / numaflow-java

Numaflow Java SDK

Apache License 2.0

22 stars 10 forks source link

feat: implement reduce stream sdk #91

Closed KeranYang closed 9 months ago

KeranYang commented 9 months ago

Define the user interface as two methods - processMessage and handleEndOfStream.
Continue using akka to handle concurrency. Introduce an OutputActor to make sure we are sending responses back to the gRPC output stream synchronously.

Testing: I developed a simple e2e test and it passed. https://github.com/KeranYang/numaflow/pull/97