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

Flink和动态模板识别

汪欣德
2023-03-14

我们计划使用Flink CEP根据一些动态模板处理大量事件。系统必须识别事件链(有时是带有条件和分组的复杂链)。模板将由用户创建。换句话说,我们必须在不接触代码的情况下创建复杂的模板。是否可以使用Apache Flink解决此问题?Filnk是否支持动态模板?

共有1个答案

曹理
2023-03-14

目前Flink的CEP库不支持这种动态规则自适应。然而,没有根本原因使其无法实现。

事实上,变化应该相当直接。目前的工作流如下:用户指定事件模式。该模式被转换为表示该模式的NFA(这发生在客户端)。然后将NFA提供给CEP操作符,该操作符被序列化并发送到集群。在集群上,CEP操作符和NFA被反序列化,然后开始处理事件。

可以添加的是一个共平面映射运算符,它在一个输入通道上接收事件和其他输入通道模式。对于每个新接收的模式,要么更新现有的NFA(缺少此功能),要么编译一个新模式。在后一种情况下,将传入事件应用于所有存储的NFA。

这样,就可以实现一个模式可以动态更新的CEP操作符。

 类似资料:
  • 问题内容: 我正在尝试根据范围值使用不同的模板进行指令。 这是我到目前为止所做的,我不知道为什么它不起作用http://jsbin.com/mibeyotu/1/edit HTML元素: 指示: 问题答案: 1)您正在将内容作为属性传递到html中。试试这个: 代替: 2)指令的数据部分正在被编译,因此您应该使用其他东西。代替数据类型,例如datan-type。 链接在这里: http://jsb

  • 我试图从动态表和基于某些字段的流中派生新表。 有没有人能为你提供最好的指导。我对flink和尝试新事物是陌生的。 书籍 ============================ BookId, Instruments, Quantity Book1, Goog,100 Book2, Vod,10 Book1, Appl,50 Book2, Goog,60 Book1, Vod,130 Book3,

  • 我想创建一个模板随机数生成器类,它可以是整数类型,也可以是浮点类型。为什么?对于赋值,我编写了一个累积函数(本质上与std::acculate相同),我想制作一个可以是任意整数或浮点类型的测试工具(例如,无符号| short | long | long long int、float、double)。我们一直在研究模板,我试图通过使用模板编程来做出动态编译时决策。我可能用了错误的方法来处理这个问题-

  • 另一个有用的可能示例:(伪代码)

  • 我们已有的几件: Post 模型定义在 models.py 中,我们有 post_list views.py 和添加的模板中。 但实际上我们如何使我们的帖子出现在我们的 HTML 模板上呢? 因为那是我们所想要的: 获取一些内容 (保存在数据库中的模型) 然后在我们的模板中很漂亮的展示,对吗? 这就是 views 应该做的: 连接模型和模板。 在我们的 post_list 视图 中我们需要获取我们

  • 我有一个我在离子中重新开发的应用程序,大约一年前我在离子v1中做过。我有多个模板类型,用户将从中选择,我想做一个动态组件,根据用户配置值加载其templateURL。因此,除了加载组件和获得正确的模板之外,一切都在进行中,除了当我运行应用程序时,它会给出模板错误,就好像它不知道ngModel是一个角属性一样。这是我所拥有的: 这是我的模板: 以下是我在Chrome开发工具中的错误: 无法绑定到ng