我正在使用Drools 6.2.0。最终,我需要使用window:time处理一组事件。每个事件都有一个日期字段。
public class Event {
private Long id;
private Date date;
...
在我的drl中:
declare org.drools.examples.broker.events.Event
@role( event )
@timestamp (date)
end
rule "test"
when
$count: Number() from accumulate (
$e: Event() over window:time(40s) from entry-point "stream" ,
count($e))
then
System.out.println("Count:" + $count);
end
场景1:使用实时并同时插入集合a事件。
session.getEntryPoint("stream").insert(e1);
session.fireAllRules();
session.getEntryPoint("stream").insert(e2);
session.fireAllRules();
session.getEntryPoint("stream").insert(e3);
session.fireAllRules();
session.getEntryPoint("stream").insert(e4);
session.fireAllRules();
场景2:使用pseudo,同时插入一个set a事件并添加到事件的偏移量时钟中。
session.getEntryPoint("stream").insert(e1);
session.fireAllRules();
clock.advanceTime(20, TimeUnit.SECONDS);
session.getEntryPoint("stream").insert(e2);
session.fireAllRules();
clock.advanceTime(40, TimeUnit.SECONDS);
session.getEntryPoint("stream").insert(e3);
session.fireAllRules();
clock.advanceTime(60, TimeUnit.SECONDS);
session.getEntryPoint("stream").insert(e4);
session.fireAllRules();
第二种情况运行良好。但我有一些问题:
谢谢
更新1
@时间戳、@持续时间等仅用于将事件关联在一起(例如A在B之前,A遇到B,依此类推),并且它们不会将事件与时钟关联起来。但是“over windows: time”基于Drools的时钟。窗口的时间使用事件插入工作内存的时刻来匹配规则。您需要使用Drools流模式。
@timestamp和“over-window:time”之间的关系是什么?如果现在,则长度为d的窗口选择包含时间戳x的事件。d
如果我需要在工作内存中插入未排序的事件(按时间戳)会发生什么?除非引擎处于“云”模式,否则您不应该这样做。时间戳基本上只是一个长值,仍然可以评估。但是,在执行此操作之前,您应该仔细考虑,因为这可能会产生不同于以正确顺序执行插入的结果。
我可以使用由我的事件表示的时间戳而不是由插入的时间表示的时间戳吗?由于DRL声明语句中的
@time戳(date)
,您似乎正在这样做。
我看到这里 老实说,我不理解这张纸条。它们是否意味着有可能用MonadPlus永远中断,例如IO Bool?比如说,IO False将破坏它。。。 当然,我可以破例或者永远实现自己的,但我的兴趣是关于这个奇怪的音符。
问题内容: 我发现了一个示例,在该示例中,将按钮添加到面板(的实例),然后将面板添加到容器(的实例),然后根据构造将容器包括在(窗口)中。 我尝试了两件事: 我摆脱了容器。在更多详细信息中,我将按钮添加到面板(实例为),然后将面板添加至窗口(实例为)。工作正常。 我摆脱了面板。在更多详细信息中,我直接将按钮添加到了容器,然后将容器添加到了窗口(的实例)。 所以,我不明白两件事。 为什么我们有两种竞
问题内容: 我最近学习了如何在工作流程中使用virtualenv和virtualenvwrapper,但是我在一些指南中看到了pyenv,但是我似乎无法理解pyenv是什么以及它与virtualenv有何不同/相似。pyenv是virtualenv的更好/更新的替代品还是免费的工具?如果后者有什么不同之处,以及两者(以及适用的virtualenvwrapper)如何一起工作? 问题答案: Pyen
我正在学习ASP.NET Core3.1。 注意到当我们开始这个项目的时候。它将转到ConfigureServices并注入一个服务。 我的问题是为什么服务可以使用那些扩展方法? 谢了。
起初,我以为nio只是基于epoll,但后来我读到nio使用sendfile。现在我完全混淆了这些概念。甚至我都怀疑我不理解埃波尔。sendfile必须使用DMA吗?nio和epoll之间的关系是什么?nio和sendfile之间的关系是什么?nio是否同时基于epoll和sendfile?
System是是System类的静态成员,那么它是如何成为的实例的?System和PrintStream是如何相互关联的?