如何通过另一个流的修订记录来更改flink中处理器的状态？

Question

Side inputs proposals可以实现我的目标。但是它仍然没有计划。

目前还有其他方法可以实现吗？

Answer 1

这取决于您的用例，您尚未概述。

通常，如果要使用侧面输入来更新状态，则这是一个查找表，需要丰富元素。有一个similar topic a few days ago。

基本上，您使用联接，理想情况下，您可以简单地使用Table API。如果在该查找之前和之后需要DataStreams，则可以将表来回转换为DataStream。

如果您的用例不涉及查找（例如，更新某些模型），则当前必须手动进行。您可以使用ProcessFunction并注册一个自定义计时器，该计时器每X分钟查找一次模型更新并相应地更新状态。

如果您提供更多详细信息，我可以定制此答案。