个人中心
文章发布
退出
作者热门文章
- html - 出于某种原因，IE8 对我的 Sass 文件中继承的 html5 CSS 不友好？
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景？
34
4
如何实现与Spark Streaming滑动窗口相同的效果，它在最后一个Y窗口长度上以X滑动间隔运行。
看Esper，应该是win:time和win:time_batch，其中win:time >= win:time_batch。
最佳答案
我通过使用 win:time 和 OUTPUT EVERY x
SELECT value
FROM Entry.win:time(10 sec)
OUTPUT EVERY 5 sec
按我的预期工作 - 每 5 秒我得到最后 10 秒的结果。
关于spark-streaming - Esper 上一个区间的滑动窗口，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/31568253/
34
4
0
我想知道使用 Esper 引擎(v5.0.0)的 java 客户端应用程序如何配置引擎实例，以便他可以连接到关系数据库，例如 pgSQL。 这对于编写能够将事件流(或数据流)与数据库中的静态/历史数据
我正在从事的项目使用 Esper 创建监控规则。这些规则是 Activity 的还是非 Activity 的，取决于 SQL 行中的 boolean 值。我想设置一个检查以查看是否有任何新的 Acti
也许您熟悉事件流处理（ESP）的概念……如果您愿意，我很想听听您使用的是什么以及它们在什么平台上使用。我是Esper项目（http://esper.codehaus.org/）的积极贡献者，但我想听听
我有一个非实时 Esper 配置，我在其中提供从文件读取的流。我正在尝试创建一个表达式来计算整个流的统计数据并在最后输出一个值。例如，Esper 具有强制 View 每 X 秒输出一次的语义，但是当您
我正在使用 Esper 来聚合我的传感器数据。数据可以以任意间隔到达，即 1 秒到 120 秒。每个数据点包含时间戳和值。 我想要 30 分钟窗口内的最小时间戳、最大时间戳、平均值和数据点计数。30
我正在使用 ESPER 进行流事件处理。我正在创建语句，然后将它们添加到 CEP 引擎，如下所示。这是处理大量(每分钟数百万个事件)数据的正确方法吗？ Configuration cepCon
据我了解，Esper 是使用查询构建的，以区分传入事件中相关的内容和不相关的内容。 我正在考虑使用 Esper，但我不确定它是否适合我的场景。 我的场景: 我需要跟踪大量客户的一些事情。我每秒将收到大
我目前在 Storm 拓扑中使用 Esper，我知道有一个名为 update() 的方法回调，当 Esper 产生结果时调用它。 我一直在想如果 Esper 引擎本身出现错误会发生什么。 是否有我可以
我有一个 Esper 查询，如下所示: @Name("MyFirstEvent") select a.groupID as groupdID,count(*) as result from pa
我是使用 esper 引擎 (java) 的新手 - 我没有在他们的文档中找到以下问题的答案: 我的事件对象有 Date 成员。此 EPL 查询语言中有哪些日期函数可用于比较日期(之前、之后)以计算两
如何实现与Spark Streaming滑动窗口相同的效果，它在最后一个Y窗口长度上以X滑动间隔运行。 看Esper，应该是win:time和win:time_batch，其中win:time >=
寻找一种使用 Esper (EPL) 语句计算 5 个 EMA5 和 EMA20 窗口内的指数移动平均线的方法。 我收到了价格事件流(时间戳、交易品种和价格)，我在 5 的滑动窗口上编写了一个简单移动
我配置了 esper 处理器来监听 kafka 中的消息。 通常select * from events.win:time(2 min)会触发最后2分钟内的所有事件现在，如果过去 2 分钟 kafka
我正在使用 Esper + Mule 并尝试定义一个 POJO 和一个事件，但在阅读了 Espero 的文档后我还没有找到我真正需要的东西。 我的事件(由 POJO 表示)具有如下属性: List W
我正在尝试构建一个在运行时动态创建和销毁 EPStatements 的应用程序，监听器设置为在数据流上的语句匹配时发送电子邮件。该电子邮件的收件人可能会根据匹配的声明而变化。 因此，我在 Esper
我正在尝试使用 EsperIO从数据库加载一些信息并在具有不同条件的其他查询中使用它。为此，我使用以下代码: ConfigurationDBRef dbConfig = new Configu
我正在编写一个应用程序，该应用程序具有包含 esper 引擎的类的实例。我想使用引擎中 EPL 的实例方法调用来读取和设置许多实例变量。我没有收到任何编译错误并且代码可以运行。但实例方法没有被调用。
有没有像sql一样在esper中写“or”的快捷方式？ 例如，如果我有以下 EPL:“select * from event(price = 2 or Price = 4 or Price = 184
假设我有一个命名窗口: CREATE WINDOW TestWindow.std:unique(FieldA) AS SELECT * FROM TestEvent; 其中，TestEvent 是 R
我对 Esper 非常陌生，我刚刚完成了教程，所以我有很多疑问。 我正在尝试进行一个查询来计算所有数据源接收到的信息的平均值。 首先，我有一个简单的查询，它只打印出我收到的所有内容: select *
我是一名优秀的程序员,十分优秀！