当前位置: 首页 > 知识库问答 >
问题:

为什么“broadcast state”可以存储动态规则,而broadcast()操作符却不能存储动态规则?

能烨华
2023-03-14

“广播状态”解除了Flink的CEP库的“动态模式”功能的实现,这意味着什么?

最后似乎得出结论:“广播状态”可以通过RichCoFlatMap存储键控流中的动态规则,而broadcast()运算符不能存储键控流中的动态规则,那么请问“广播状态”是如何通过RichCoFlatMap存储键控流中的动态规则的,为什么broadcast()运算符不能通过RichCoFlatMap存储键控流中的动态规则呢?能给我一个解释它的例子吗?

共有1个答案

徐学潞
2023-03-14

这完全是两个不同的概念。此外,broadcast()broadcaststate的先决条件。

broadcast()指定数据的分区,即流的每个元素都应该广播给每个并行下游运算符

broadcaststate是运算符的一种状态,它首先允许从广播流读写和从非广播流读。在此之前,没有办法将这两条溪流连接起来。此外,该状态将确保在还原之后,所有并行实例的每个实例的状态都是相同的。

 类似资料:
  • 规则 Sentinel 的理念是开发者只需要关注资源的定义,当资源定义成功后可以动态增加各种流控降级规则。Sentinel 提供两种方式修改规则: 通过 API 直接修改 (loadRules) 通过 DataSource 适配不同数据源修改 手动通过 API 修改比较直观,可以通过以下几个 API 修改不同的规则: FlowRuleManager.loadRules(List<FlowRule>

  • 我目前正在使用NodeJS、HTML和Firebase编写一个web站点,用于数据库服务、身份验证和存储。我目前遇到的问题是Firebase存储规则不能按照我对文档的解释工作。 我的Firebase存储实例的目录结构如下所示(明显有假的UID):

  • 只是一个关于如何实现多个Firebase存储安全规则的简短问题。 事实上,我想限制可以上传的文件的大小,但保留我的认证规则。 我一直在阅读上一篇文章,它给了我一个关于如何限制每个文件的上传大小的提示,但我仍然在努力实现“匹配/files/{fileName}”与身份验证规则的某个地方。 经过多次尝试,这是我在写这篇文章之前的最后一次迭代: 当然,我确实阅读了官方文档,但似乎我仍然无法正确理解。

  • 拒绝许可。无法访问存储桶..请访问Firebase控制台中的Storage选项卡,为您的存储桶启用Firebase存储,并确保您有足够的权限来正确提供资源 在谷歌搜索如何设置这些安全规则,我不确定什么是正确的答案。一些答案建议我在代码中编写方法来授予权限,但文档建议我需要在Firebase的端进行。 这是其中一个例子 我无法理解人们的回答 就像几个月前的这张 有人能解释一下当前的Firebase(

  • 有没有一种方法可以通过使用集合名称变量来概括它

  • 谈到动态规划,很多人会疑惑动态规划难吗?说实话很难,特别是对于初学者来说,入门动态规划的时候,举个例子,看 0-1背包问题,很容易就被题目弄懵了。就算看的懂答案,但就是自己不会做,不知道怎么下手。就像做递归的题,看的懂答案,但下不了手。 对于动态规划,好多题都会用到,如果你对动态规划感兴趣,或者你不知道怎么下手,那么这篇文章的将会系统的介绍什么是动态规划,帮助大家做题。 为了兼顾初学者,我会从最简