wso2cep

    0热度

    1回答

    我正在使用WSO2 Data Analytics Server。我通过一个HTTP接收器接收我的事件,并且我做了一个仪表板实时查看信息。收到事件时,图形会更新,但如果我尝试最大化小工具(甚至刷新页面),图形数据就会消失。任何人都知道为什么? Picutre 1: Before I maximize Picture 2: When I'm maximizing

    0热度

    1回答

    我有以下查询: from stream1 select count() as item insert into newStream; 是否有可能重启流的count()函数? 如果不是,我怎样才能绕过这个?如果可能的话。

    0热度

    1回答

    我有捕捉流场的最高值的查询: from stream1#window.time(1 min) select max(value1) as max_value1 insert all events into newstream; 虽然,这个窗口后,我开始变得在零值max_value1。 我对avg做了同样的事情,但是一旦所有事件从1分钟时间窗口过期,我总是得到0。

    1热度

    1回答

    我试图在linux虚拟机上构建一个Wso2 CEP的docker镜像。 我在运行./build.sh脚本失败,我收到以下错误meassage 泊坞版本应当等于或大于1.10.0更大打造WSO2泊坞的图像。发现17.03.0策 我怎样才能解决这个搬运工的版本问题? 谢谢

    0热度

    2回答

    我正在使用wso2CEP的docker镜像。 我想事件接收器和发布服务器将连接到JMS(ActiveMQ) ,并在未来可能其他客户端(Kafka)或cassandra或http。 如何将此支持添加到dockerized CEP?我不想用所需的罐子重建图像 。有没有不同的方式来提供它? 谢谢 托默

    0热度

    1回答

    我对WSO2 CEP Siddhi QL相当陌生,我得到了一个分析流入事件的要求。 对于回:我的数据来在这样的[ID,值]: InputStream=[1001,90] InputStream=[1001,85] InputStream=[1002,70] InputStream=[1001,85] InputStream=[1003,70] InputStream=[1003,85]

    0热度

    1回答

    我有一个CEP流,每秒处理超过100条消息的吞吐量很高。 而且我出版我的处理结果为JMS发布者具有以下配置: Output Event Adapter Type* : JMS JNDI Initial Context Factory Class: org.apache.activemq.jndi.ActiveMQInitialContextFactory JNDI Provider URL *

    0热度

    1回答

    从下面的流中,我想要警告在温度超过90°时发生两次的事件(如每次2个事件的温度> 90需要被警告)。 InputStream=[1001,91] InputStream=[1001,86] InputStream=[1002,70] InputStream=[1001,85] InputStream=[1003,70] InputStream=[1003,85] InputStream

    0热度

    1回答

    我有一个关于GEO扩展“内”功能的问题。 我有多个事件流,其中包含传感器信息,包括每个传感器的位置(地理坐标和高程)。 此外,我有一个多边形(下面的例子,其中包含每个点的坐标)。 我想检查是否有可能确定传感器是否在这个多边形的边界内,在三维空间中。 多边形JSON格式的示例: [ { "long": 172.638741916196, "lat": -43.527

    1热度

    1回答

    我正在将函数内的GEO扩展用于执行计划。 我有多个事件流,其中包含传感器信息,包括每个传感器的位置(在地理坐标中)。 此外,我有一个多边形(下面的例子,其中包含每个点的坐标)。我想检查是否有可能确定传感器是否在这个多边形的边界内。 我的执行计划如下: 您有:在WSO2CEP管理控制台以下错误发生的 @Plan:name('TestExecutionPlan') define stream se