search

apache / rocketmq-streams

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

Finish data processing when function return null. #246

Closed ni-ze closed 1 year ago

ni-ze commented 1 year ago

In map and flatmap function, no data will be produced in some scenes, so there is no necessary pass it to next function.

Jargon9 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 provide more detail? For example, I'm wondering whether I should close the whole stream or just not pass the data to the next function and directly output to the sink.

elenacliu commented 1 year ago

hi, I'm doing this these days, plz assign it to me.

elenacliu commented 1 year ago

After more insight into the project, I think I should stop forward the data to the next processor node if the data output is null

Can you provide more detail? For example, I'm wondering whether I should close the whole stream or just not pass the data to the next function and directly output to the sink.