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: user@flink.apache.
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
Hi Flink Users,
I have a BroadcastProcessFunction and in the processElement method I sometimes
need to do some http requests, depending on the broadcast state.
Because I'm doing http requests, I'd prefer the function to be async, like
RichAsyncFunction.asyncInvoke(), but RichAsyncFunction
