Siddhi用于过滤部分

Question

我的传入事件包含userId属性。我希望能够根据userId从CQEngine读取参数值。我是否应该将其作为FunctionExecutor的扩展来实现，并将其使用如下：

define stream cseEventStream (userId string, symbol string, price long, volume long);
@info(name = 'query1')
from cseEventStream [price < custom:cache(userId)]
select *
insert into Output

或者有什么更好的方法去做。问题是，在第一次使用CQEngine之前，我需要用数据初始化它。FunctionExecutor的“开始”方法可能会用于这个目的吗？

Answer 1

您可以继续使用FunctionExecutor并在init()或start()中实现初始化逻辑。每一个函数的使用都会被调用一次。调用顺序是init()，其次是start()。但是，根据API，建议使用start()来获取处理元素所需的资源。和stop()来释放获得的资源。