- 如果您觉得本站非常有看点，那么赶紧使用Ctrl+D 收藏吧
在我们现有的应用程序中，我们使用的是Esper版本5.3。我们添加了一些addPlugInSingleRowFunction（）以便在EPL中使用它，如下所示-
最终配置cepConfiguration = new Configuration（）;cepConfiguration.addPlugInSingleRowFunction（“ toNumber”，……继续阅读 »
当我使用Flink CEP代码处理时间（默认情况下是配置）时，我能够获得所需的模式匹配，但是在将环境配置为事件时间时，我无法获得任何模式匹配。
def main(args: Array[String]): Unit = {
val env = StreamExecutionEnvironment.getExecutionEnvironment
……继续阅读 »
我正在尝试使用Esper Dataflows做一些测试，所以我正在使用Esper Dataflows提供的Select运算符编写一些模式。但是我没有让它工作。我正在尝试执行以下代码：
public class BenchmarkEvent {
long ReceivedTimestamp;
long ProcessedTimestam……继续阅读 »
在很长一段时间内寻找解决方案：
我有联系表。每当有人通过它发送邮件时，都会向Esper发送一个ContactEvent（receiver，senderIpAddress）。现在，当特定的IP地址在10分钟内发出超过50个联系事件时，我希望Esper通知我。
以下代码中的语法错误是由于代码简化导致的
create window ContactWindow.wi……继续阅读 »
