每次从流中提取数据时，我都必须从flink process元素从Rest API中提取数据，我如何才能做到这一点，我找不到足够的数据来异步调用Rest服务。请帮我拿一些样品。
所有作业都发生在RichAsyncFunction的asyncInvoke内。因此，为了能够调用REST服务，您需要使用一些异步HTTP客户端(从技术上讲，它可能是一个同步客户端，但这没有意义(。这里可以找到异步http客户端使用的示例。
因此，当你执行异步请求时，你所需要做的就是在你的请求处理程序中调用resultFuture.complete，这样结果就会在Flink中传递到下游。