cep

0热度

1回答

我有一个显示来自Stream的信息图。我想在其他java应用程序中使用这个仪表板。有前提吗？可以吗？感谢您的意见。

0热度

1回答

在路径C：\ wso2 \ wso2das-3.0.1 \ repository \ components中有一个artifacts.xml文件。这个文件的功能是什么？我可以修改此文件的补充一点，我使用的新libreries延长神功？例如： jaxrs-api-3.0.2.Final.jar resteasy-client-3.0.2.Final.jar resteasy-jaxrs-3.

0热度

1回答

Esper用户定义的函数，需要两个参数

我想编写一个esper epl表达式，它根据用户定义的函数返回的返回值来过滤事件，我的用户定义的函数一次必须带两个事件对象。所以我写了一个这样的查询。 select window(*), 'CANDLE NAME' as candleType from CandleStickEvent(myFunction(*) = 'true').win:length(2) 虽然这个工作一次只传递一个Ca

0热度

1回答

Drools 6融合通知

我们正在使用drools 6（Fusion）的一个非常复杂的解决方案中工作，我希望您能够阅读关于读取关联结果期间创建的对象的最佳方法。我的第一个基本方法是每隔一段时间阅读工作内存，寻找新对象并将它们报告给外部服务（REST）。AgendaEventListener似乎并不是最好的方法，因为我不关心大多数被插入到工作内存中的对象，所以也许最好的方法是在DRL内的某种服务中注入特定的“对象”。这是一

1热度

1回答

Ho我可以和Flink CEP做一个懒惰的匹配吗

我想用FlinkCEP只在模式上做一个'懒惰'匹配。我怎样才能做到这一点？例如我有一个输入流ACABCABCB，我想匹配A后面的C得到只有3场比赛，而不是6场比赛。我创建了以下示例来说明我的问题。 val env = StreamExecutionEnvironment.createLocalEnvironment(1) env.setStreamTimeCharacteristic(Tim

0热度

1回答

wso2 DAS仪表板的架构

我想知道我的仪表板从哪里获取信息。这些信息在文件或RDBMS中存储在哪里？我想将WSO2仪表板更改为TABLEU。可能吗？

0热度

1回答

如何正确配置cepheus cep每小时重新计算属性？

让我再解释一下。我有这个CEP配置： { "host":"http://localhost:1028", //Cepheus CEP "in":[ { "id":"A.*", "type":"Pevent", "isPattern":true, "providers":[ "http://localhost

0热度

1回答

在siddhi加入触发器

我有问题。我正在使用DAS 3.0.1。 Trazablack是一个postgres表。我不能让与事件Trazafiltrada联接，它是用下面的代码创建： define trigger FiveMinTriggerStream at every 5 min; from FiveMinTriggerStream join Trazablack as t select t.sensorVal

0热度

2回答

用于监控系统的CEP

我很感兴趣什么是实施CEP（复杂事件处理）系统进行监控的方式。我需要监视很多设备，并且需要使用事件过滤器来比较结果。这个特定情况下是否有任何现代体系结构？

0热度

1回答

REST服务wso2 DAS或CEP

我可以调用服务REST，它使用来自siddhi的HTTP类型的其他输入流的参数吗？例如：我有一个输入流sensorStream： @Import('org.wso2.event.sensor.stream:1.0.0') define stream sensorStream (meta_timestamp long, meta_isPowerSaverEnabled bool, meta_s