如何使用ESPER性能套件来测量具有单行函数的查询的延迟和吞吐量

Question

我编写了一些在查询中使用单行函数的ESPER CEP查询。

现在，我想使用ESPER性能套件测量查询的延迟和吞吐量。

所以我在statement.properties中添加了我的查询，但我不确定应该如何以及在哪里编写单行函数。我可以在statement.properties本身中编写它吗？下面是我的单行函数compute_average的查询

Tsinglerowfn = select '$' as  ticker, compute_average(e) from Market(ticker='$')#time(5 seconds) as e

如何使用性能套件在ESPER中测量具有单行功能的查询的性能？

Answer 1

是的，您可以将EPL添加到属性中。您需要确保“compute_avg”在配置中注册为预定义的单行函数。为此，您需要调出IDE，因为未在属性文件中完成。

如果函数计算某种平均值，这是一个有状态的概念，则应该使用聚合函数扩展API而不是单行函数，就像无状态函数代码一样。