apache / rocketmq-streams

Apache rocketmq
https://rocketmq.apache.org/
Apache License 2.0
171 stars 82 forks source link

Support flatMap function in GroupedStream #247

Closed ni-ze closed 1 year ago

ni-ze commented 1 year ago

flatmap function takes one element and produces zero, one, or more elements. such as, a flatmap function splits sentences to words:

flatmap("hello world") -> "hello" "world"

selectbook commented 1 year ago

please assign it to me

joeCarf commented 1 year ago

I'd like to do this. plz assign it to me

elenacliu commented 1 year ago

Can you assign it to me? I‘m working on this these days.