Re: RichAsyncFunction + BroadcastProcessFunction

2020-03-17 Thread John Morrow
unction if (item.inventory != null && item.inventory < X) { ctx.output("reorder-outputTag", item) } item.status = "checked"; collect(item); } From: Tzu-Li (Gordon) Tai Sent: Tuesday 17 March 2020 10:05 To: use

Re: RichAsyncFunction + BroadcastProcessFunction

2020-03-17 Thread Tzu-Li (Gordon) Tai
Hi John, Have you considered letting the BroadcastProcessFunction output events that indicate extra external HTTP requests needs to be performed, and have them consumed by a downstream async IO operator to complete the HTTP request? That could work depending on what exactly you need to do in your