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
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