我的目标是实现基于动态规则的流数据集验证。我的项目正在使用 Pyflink。我知道 Flink 中有一个广播模式,但在 Python 中没有找到任何可靠的信息。Pyflink 中是否提供此功能?如果没有,是否有任何解决方法可以在 Pyflink 中实现动态规则
我的目标是实现基于动态规则的流数据集验证。我的项目正在使用 Pyflink。我知道 Flink 中有一个广播模式,但在 Python 中没有找到任何可靠的信息。Pyflink 中是否提供此功能?如果没有,是否有任何解决方法可以在 Pyflink 中实现动态规则