使用Esper，如何对事件进行动态过滤？

Question

我是在 Java 中使用 Esper 事件流引擎的新手。场景是事件作为 POJO 传入。他们有一个我想过滤的字段。过滤后的值将随时间而变化。我不希望每次发生更改时都删除并插入新语句。

示例：

事件名为“MyEvent”，并具有字段“来源”。值可以是“家庭”、“工作”或“学校”之一。 Web 服务允许用户更改他们感兴趣的“源”值。 英超联赛的声明将是这样的：

select * from MyEvent where source in ( 'home', 'school' )

所以在任何时候，“学校”都可能被删除，并且必须尽快反映其影响。问题是，如何最好地实现这一目标？由于更新生效之间存在延迟，我排除了缓存的数据库调用。

想法是：

1) 拥有一个名为“SourcesOfInterest”的流，其中包含列表类型的“sources”字段，并将语句更改为：

select * from MyEvent where source in (SourcesOfInterest.win:length(1).sources)

Web 服务将“SourcesOfInterest”事件插入到此流中，其中仅查看最新的事件。 甚至不确定语法是否正确。

2) 让语句引用运行时变量。那么语句将是：

select * from MyEvent where source in ( mySourcesVariable )

Web 服务将调用

EPRuntime.setVariableValue( "mySourcesVariable", myArrayOfSources )

还有其他选项吗？其中任何一个的性能问题？

Answer 1

经过一番思考后，我使用了问题中的第二个想法。

在配置中设置该变量

在启动之前，需要使用SetmySetOfValues = new HashSet();

esperConfiguration.addVariable( mySourcesVariable, Set.class, mySetOfValues );

Web 服务按描述工作，使用 Set 而不是数组。

现在一切都很好，而且性能也不错，所以我就这么做了。