2:57 p.m.
Hi guys,
We made some experiments with Drools Fusion and we wonder if there is any
way to speed it up. In our experiments, we detected complex events in
streams of stock tickers and got times significantly slower with Drools than
with other CEP systems (and also higher memory consumption in the same order
of magnitude):
Number of events Drools 5.0 Fusion Esper 3.1.0 Etalis with SWI Prolog Etalis
with Yap Prolog
10000 1179 453 328 265 (time in miliseconds to process the stream of events)
20000 2359 828 701 531
30000 3538 1141 1023 780
40000 4718 1500 1356 1078
50000 5897 1813 1702 1329
I can provide some of our code if someone needs it (beside what I pasted
below).
Please tell me if you know any obvious optimizations? Or if you think this
is due to Java (vs. C in other implementations), or any other reasons.
Thank you, regards,
Paul Fodor
Our program has 5 rules to detect complex events:
fusion.drl:
rule "experiment A -Rule 0/0"
when
$ae1 :Event(symbol == 1, $Pr1 : price) and
$ce1 :Event(this after $ae1 , symbol == 1, price > ($Pr1/1.2) )
then
//System.out.println("Ce1 fired !");
end
rule "experiment A -Rule 0/1"
when
(
$ae2 :Event(symbol == 2,$Pr2 : price) and
$ce2 : Event(this after $ae2 , symbol == 2,price > ($Pr2/1.2) )
)
then
//System.out.println("Ce2 fired !");
end
rule "experiment A -Rule1"
when
(
$ae1 :Event(symbol == 1, $Pr1 : price) and
$ce1 :Event(this after $ae1 , symbol == 1, price > ($Pr1/1.2) )
)
or
(
$ae2 :Event(symbol == 2,$Pr2 : price) and
$ce2 : Event(this after $ae2 , symbol == 2,price > ($Pr2/1.2) )
)
then
//System.out.println("Ce3 fired !");
end
rule "experiment A -Rule4"
when
(
$ae1 :Event(symbol == 1, $Pr1 : price) and
$ce1 :Event(this after $ae1 , symbol == 1, price > ($Pr1/1.2) )
)
and
(
$ae2 :Event(symbol == 2,$Pr2 : price) and
$ce2 : Event(this after $ae2 , symbol == 2,price > ($Pr2/1.2) , this
after[0,20m] $ce1 )
)
then
//System.out.println("Ce4 fired !");
end
rule "experiment A -Rule5"
when
(
$ae1 :Event(symbol == 1, $Pr1 : price) and
$ce1 :Event(this after $ae1 , symbol == 1, price > ($Pr1/1.2))
)
and
(
$ae2 :Event(symbol == 2,$Pr2 : price) and
$ce2 : Event(this after $ae2 , symbol == 2,price > ($Pr2/1.2) , this
overlaps $ce1)
)
then
//System.out.println("Ce5 fired !");
end
We have an Event class for events with its parameters and an EventStream
class to fire the events:
EventStream.java:
...
import org.drools.runtime.StatefulKnowledgeSession;
public class EventStream {
public StatefulKnowledgeSession get_working_session() { return ksession;}
...
void generateEventStream(double duration, double p) {
...
//Drools
Event temp = new Event(symbol,currValue);
ksession.insert(temp);
...
}
}
3:45 p.m.
First of all you can try adding:
$ae1 :Event(symbol == 1, $Pr1 : price) and
$ce1 :Event(this != $ae1, symbol == 1, price > ($Pr1/1.2), this after $ae1
)
That will avoid the cross product.
Post again the result with that.
2009/9/17 PF <pif1979(a)gmail.com>
Hi guys,
We made some experiments with Drools Fusion and we wonder if there is any
way to speed it up. In our experiments, we detected complex events in
streams of stock tickers and got times significantly slower with Drools than
with other CEP systems (and also higher memory consumption in the same order
of magnitude):
Number of events Drools 5.0 Fusion Esper 3.1.0 Etalis with SWI Prolog
Etalis with Yap Prolog
10000 1179 453 328 265 (time in miliseconds to process the stream of
events)
20000 2359 828 701 531
30000 3538 1141 1023 780
40000 4718 1500 1356 1078
50000 5897 1813 1702 1329
I can provide some of our code if someone needs it (beside what I pasted
below).
Please tell me if you know any obvious optimizations? Or if you think this
is due to Java (vs. C in other implementations), or any other reasons.
Thank you, regards,
Paul Fodor
Our program has 5 rules to detect complex events:
fusion.drl:
rule "experiment A -Rule 0/0"
when
$ae1 :Event(symbol == 1, $Pr1 : price) and
$ce1 :Event(this after $ae1 , symbol == 1, price > ($Pr1/1.2) )
then
//System.out.println("Ce1 fired !");
end
rule "experiment A -Rule 0/1"
when
(
$ae2 :Event(symbol == 2,$Pr2 : price) and
$ce2 : Event(this after $ae2 , symbol == 2,price > ($Pr2/1.2) )
)
then
//System.out.println("Ce2 fired !");
end
rule "experiment A -Rule1"
when
(
$ae1 :Event(symbol == 1, $Pr1 : price) and
$ce1 :Event(this after $ae1 , symbol == 1, price > ($Pr1/1.2) )
)
or
(
$ae2 :Event(symbol == 2,$Pr2 : price) and
$ce2 : Event(this after $ae2 , symbol == 2,price > ($Pr2/1.2) )
)
then
//System.out.println("Ce3 fired !");
end
rule "experiment A -Rule4"
when
(
$ae1 :Event(symbol == 1, $Pr1 : price) and
$ce1 :Event(this after $ae1 , symbol == 1, price > ($Pr1/1.2) )
)
and
(
$ae2 :Event(symbol == 2,$Pr2 : price) and
$ce2 : Event(this after $ae2 , symbol == 2,price > ($Pr2/1.2) , this
after[0,20m] $ce1 )
)
then
//System.out.println("Ce4 fired !");
end
rule "experiment A -Rule5"
when
(
$ae1 :Event(symbol == 1, $Pr1 : price) and
$ce1 :Event(this after $ae1 , symbol == 1, price > ($Pr1/1.2))
)
and
(
$ae2 :Event(symbol == 2,$Pr2 : price) and
$ce2 : Event(this after $ae2 , symbol == 2,price > ($Pr2/1.2) , this
overlaps $ce1)
)
then
//System.out.println("Ce5 fired !");
end
We have an Event class for events with its parameters and an EventStream
class to fire the events:
EventStream.java:
...
import org.drools.runtime.StatefulKnowledgeSession;
public class EventStream {
public StatefulKnowledgeSession get_working_session() { return ksession;}
...
void generateEventStream(double duration, double p) {
...
//Drools
Event temp = new Event(symbol,currValue);
ksession.insert(temp);
...
}
}
_______________________________________________
rules-users mailing list
rules-users(a)lists.jboss.org
https://lists.jboss.org/mailman/listinfo/rules-users
--
- http://salaboy.wordpress.com
- http://www.jbug.com.ar
- Salatino "Salaboy" Mauricio -
4:36 p.m.
2009/9/17 Mauricio Salatino <salaboy(a)gmail.com>
First of all you can try adding:
$ae1 :Event(symbol == 1, $Pr1 : price) and
$ce1 :Event(this != $ae1, symbol == 1, price > ($Pr1/1.2), this after $ae1
)
That will avoid the cross product.
Post again the result with that.
Hi Mauricio,
Your advice helped a bit, but not very much (please see below). I also
modified the test for Drools to show the event/sec throughput using Timer
instead of fixed number of events per time. I think it's more helpful this
way.
New run:
No. of events/second is: 7135.
No. of events/second is: 8358.
No. of events/second is: 8218.
No. of events in total is: 23715.
No. of total events/second is: 7905.333333333333
Memory used:16872192
Old rule file:
No. of events/second is: 7441.
No. of events/second is: 8133.
No. of events/second is: 7688.
No. of events in total is: 23263.
No. of total events/second is: 7754.666666666667
Memory used:16892760
Paul.
2009/9/17 PF <pif1979(a)gmail.com>
> Hi guys,
> We made some experiments with Drools Fusion and we wonder if there is any
> way to speed it up. In our experiments, we detected complex events in
> streams of stock tickers and got times significantly slower with Drools than
> with other CEP systems (and also higher memory consumption in the same order
> of magnitude):
> Number of events Drools 5.0 Fusion Esper 3.1.0 Etalis with SWI Prolog
> Etalis with Yap Prolog
> 10000 1179 453 328 265 (time in miliseconds to process the stream of
> events)
> 20000 2359 828 701 531
> 30000 3538 1141 1023 780
> 40000 4718 1500 1356 1078
> 50000 5897 1813 1702 1329
>
> I can provide some of our code if someone needs it (beside what I pasted
> below).
> Please tell me if you know any obvious optimizations? Or if you think this
> is due to Java (vs. C in other implementations), or any other reasons.
> Thank you, regards,
> Paul Fodor
> Our program has 5 rules to detect complex events:
> fusion.drl:
> rule "experiment A -Rule 0/0"
> when
> $ae1 :Event(symbol == 1, $Pr1 : price) and
> $ce1 :Event(this after $ae1 , symbol == 1, price > ($Pr1/1.2) )
> then
> //System.out.println("Ce1 fired !");
> end
> rule "experiment A -Rule 0/1"
> when
> (
> $ae2 :Event(symbol == 2,$Pr2 : price) and
> $ce2 : Event(this after $ae2 , symbol == 2,price > ($Pr2/1.2) )
> )
> then
> //System.out.println("Ce2 fired !");
> end
> rule "experiment A -Rule1"
> when
> (
> $ae1 :Event(symbol == 1, $Pr1 : price) and
> $ce1 :Event(this after $ae1 , symbol == 1, price > ($Pr1/1.2) )
> )
> or
> (
> $ae2 :Event(symbol == 2,$Pr2 : price) and
> $ce2 : Event(this after $ae2 , symbol == 2,price > ($Pr2/1.2) )
> )
> then
> //System.out.println("Ce3 fired !");
> end
>
> rule "experiment A -Rule4"
> when
> (
> $ae1 :Event(symbol == 1, $Pr1 : price) and
> $ce1 :Event(this after $ae1 , symbol == 1, price > ($Pr1/1.2) )
> )
> and
> (
> $ae2 :Event(symbol == 2,$Pr2 : price) and
> $ce2 : Event(this after $ae2 , symbol == 2,price > ($Pr2/1.2) , this
> after[0,20m] $ce1 )
> )
> then
> //System.out.println("Ce4 fired !");
> end
>
> rule "experiment A -Rule5"
> when
> (
> $ae1 :Event(symbol == 1, $Pr1 : price) and
> $ce1 :Event(this after $ae1 , symbol == 1, price > ($Pr1/1.2))
> )
> and
> (
> $ae2 :Event(symbol == 2,$Pr2 : price) and
> $ce2 : Event(this after $ae2 , symbol == 2,price > ($Pr2/1.2) , this
> overlaps $ce1)
> )
> then
> //System.out.println("Ce5 fired !");
> end
>
> We have an Event class for events with its parameters and an EventStream
> class to fire the events:
> EventStream.java:
> ...
> import org.drools.runtime.StatefulKnowledgeSession;
> public class EventStream {
> public StatefulKnowledgeSession get_working_session() { return ksession;}
> ...
> void generateEventStream(double duration, double p) {
> ...
> //Drools
> Event temp = new Event(symbol,currValue);
> ksession.insert(temp);
> ...
> }
> }
>
>
> _______________________________________________
> rules-users mailing list
> rules-users(a)lists.jboss.org
> https://lists.jboss.org/mailman/listinfo/rules-users
>
>
--
- http://salaboy.wordpress.com
- http://www.jbug.com.ar
- Salatino "Salaboy" Mauricio -
_______________________________________________
rules-users mailing list
rules-users(a)lists.jboss.org
https://lists.jboss.org/mailman/listinfo/rules-users
4:52 p.m.
heh that's my first approach...
The memory usage is normal I think, because you are creating a lot of
objects and they are kept in memory.
Can you share the project that you are using with us? so I can test the
performance in my machine?
your machine details will be also necessary.
Thanks!
2009/9/17 PF <pif1979(a)gmail.com>
2009/9/17 Mauricio Salatino <salaboy(a)gmail.com>
> First of all you can try adding:
> $ae1 :Event(symbol == 1, $Pr1 : price) and
> $ce1 :Event(this != $ae1, symbol == 1, price > ($Pr1/1.2), this after
> $ae1 )
>
> That will avoid the cross product.
> Post again the result with that.
Hi Mauricio,
Your advice helped a bit, but not very much (please see below). I also
modified the test for Drools to show the event/sec throughput using Timer
instead of fixed number of events per time. I think it's more helpful this
way.
New run:
No. of events/second is: 7135.
No. of events/second is: 8358.
No. of events/second is: 8218.
No. of events in total is: 23715.
No. of total events/second is: 7905.333333333333
Memory used:16872192
Old rule file:
No. of events/second is: 7441.
No. of events/second is: 8133.
No. of events/second is: 7688.
No. of events in total is: 23263.
No. of total events/second is: 7754.666666666667
Memory used:16892760
Paul.
> 2009/9/17 PF <pif1979(a)gmail.com>
>
>> Hi guys,
>> We made some experiments with Drools Fusion and we wonder if there is any
>> way to speed it up. In our experiments, we detected complex events in
>> streams of stock tickers and got times significantly slower with Drools than
>> with other CEP systems (and also higher memory consumption in the same order
>> of magnitude):
>> Number of events Drools 5.0 Fusion Esper 3.1.0 Etalis with SWI Prolog
>> Etalis with Yap Prolog
>> 10000 1179 453 328 265 (time in miliseconds to process the stream of
>> events)
>> 20000 2359 828 701 531
>> 30000 3538 1141 1023 780
>> 40000 4718 1500 1356 1078
>> 50000 5897 1813 1702 1329
>>
>> I can provide some of our code if someone needs it (beside what I pasted
>> below).
>> Please tell me if you know any obvious optimizations? Or if you think
>> this is due to Java (vs. C in other implementations), or any other reasons.
>> Thank you, regards,
>> Paul Fodor
>> Our program has 5 rules to detect complex events:
>> fusion.drl:
>> rule "experiment A -Rule 0/0"
>> when
>> $ae1 :Event(symbol == 1, $Pr1 : price) and
>> $ce1 :Event(this after $ae1 , symbol == 1, price > ($Pr1/1.2) )
>> then
>> //System.out.println("Ce1 fired !");
>> end
>> rule "experiment A -Rule 0/1"
>> when
>> (
>> $ae2 :Event(symbol == 2,$Pr2 : price) and
>> $ce2 : Event(this after $ae2 , symbol == 2,price > ($Pr2/1.2) )
>> )
>> then
>> //System.out.println("Ce2 fired !");
>> end
>> rule "experiment A -Rule1"
>> when
>> (
>> $ae1 :Event(symbol == 1, $Pr1 : price) and
>> $ce1 :Event(this after $ae1 , symbol == 1, price > ($Pr1/1.2) )
>> )
>> or
>> (
>> $ae2 :Event(symbol == 2,$Pr2 : price) and
>> $ce2 : Event(this after $ae2 , symbol == 2,price > ($Pr2/1.2) )
>> )
>> then
>> //System.out.println("Ce3 fired !");
>> end
>>
>> rule "experiment A -Rule4"
>> when
>> (
>> $ae1 :Event(symbol == 1, $Pr1 : price) and
>> $ce1 :Event(this after $ae1 , symbol == 1, price > ($Pr1/1.2) )
>> )
>> and
>> (
>> $ae2 :Event(symbol == 2,$Pr2 : price) and
>> $ce2 : Event(this after $ae2 , symbol == 2,price > ($Pr2/1.2) , this
>> after[0,20m] $ce1 )
>> )
>> then
>> //System.out.println("Ce4 fired !");
>> end
>>
>> rule "experiment A -Rule5"
>> when
>> (
>> $ae1 :Event(symbol == 1, $Pr1 : price) and
>> $ce1 :Event(this after $ae1 , symbol == 1, price > ($Pr1/1.2))
>> )
>> and
>> (
>> $ae2 :Event(symbol == 2,$Pr2 : price) and
>> $ce2 : Event(this after $ae2 , symbol == 2,price > ($Pr2/1.2) , this
>> overlaps $ce1)
>> )
>> then
>> //System.out.println("Ce5 fired !");
>> end
>>
>> We have an Event class for events with its parameters and an EventStream
>> class to fire the events:
>> EventStream.java:
>> ...
>> import org.drools.runtime.StatefulKnowledgeSession;
>> public class EventStream {
>> public StatefulKnowledgeSession get_working_session() { return
>> ksession;}
>> ...
>> void generateEventStream(double duration, double p) {
>> ...
>> //Drools
>> Event temp = new Event(symbol,currValue);
>> ksession.insert(temp);
>> ...
>> }
>> }
>>
>>
>> _______________________________________________
>> rules-users mailing list
>> rules-users(a)lists.jboss.org
>> https://lists.jboss.org/mailman/listinfo/rules-users
>>
>>
>
>
> --
> - http://salaboy.wordpress.com
> - http://www.jbug.com.ar
> - Salatino "Salaboy" Mauricio -
>
> _______________________________________________
> rules-users mailing list
> rules-users(a)lists.jboss.org
> https://lists.jboss.org/mailman/listinfo/rules-users
>
>
_______________________________________________
rules-users mailing list
rules-users(a)lists.jboss.org
https://lists.jboss.org/mailman/listinfo/rules-users
--
- http://salaboy.wordpress.com
- http://www.jbug.com.ar
- Salatino "Salaboy" Mauricio -
6:57 a.m.
I'm also seeing that you are not using fusion, because you are not using
entry-points.
You are only creating POJOs and inserting them as facts in a loop.
did you check the fusion example project?
http://anonsvn.jboss.org/repos/labs/labs/jbossrules/trunk/drools-examples...
you also should check the docs, specially:
http://hudson.jboss.org/hudson/job/drools/lastSuccessfulBuild/artifact/tr...
Greetings
On Thu, Sep 17, 2009 at 2:52 PM, Mauricio Salatino <salaboy(a)gmail.com>wrote:
heh that's my first approach...
The memory usage is normal I think, because you are creating a lot of
objects and they are kept in memory.
Can you share the project that you are using with us? so I can t
est the performance in my machine?
your machine details will be also necessary.
Thanks!
2009/9/17 PF <pif1979(a)gmail.com>
> 2009/9/17 Mauricio Salatino <salaboy(a)gmail.com>
>
>> First of all you can try adding:
>> $ae1 :Event(symbol == 1, $Pr1 : price) and
>> $ce1 :Event(this != $ae1, symbol == 1, price > ($Pr1/1.2), this after
>> $ae1 )
>>
>> That will avoid the cross product.
>> Post again the result with that.
>
> Hi Mauricio,
> Your advice helped a bit, but not very much (please see below). I also
> modified the test for Drools to show the event/sec throughput using Timer
> instead of fixed number of events per time. I think it's more helpful this
> way.
> New run:
> No. of events/second is: 7135.
> No. of events/second is: 8358.
> No. of events/second is: 8218.
> No. of events in total is: 23715.
> No. of total events/second is: 7905.333333333333
> Memory used:16872192
>
> Old rule file:
> No. of events/second is: 7441.
> No. of events/second is: 8133.
> No. of events/second is: 7688.
> No. of events in total is: 23263.
> No. of total events/second is: 7754.666666666667
> Memory used:16892760
>
> Paul.
>
>
>> 2009/9/17 PF <pif1979(a)gmail.com>
>>
>>> Hi guys,
>>> We made some experiments with Drools Fusion and we wonder if there is
>>> any way to speed it up. In our experiments, we detected complex events in
>>> streams of stock tickers and got times significantly slower with Drools than
>>> with other CEP systems (and also higher memory consumption in the same order
>>> of magnitude):
>>> Number of events Drools 5.0 Fusion Esper 3.1.0 Etalis with SWI Prolog
>>> Etalis with Yap Prolog
>>> 10000 1179 453 328 265 (time in miliseconds to process the stream of
>>> events)
>>> 20000 2359 828 701 531
>>> 30000 3538 1141 1023 780
>>> 40000 4718 1500 1356 1078
>>> 50000 5897 1813 1702 1329
>>>
>>> I can provide some of our code if someone needs it (beside what I pasted
>>> below).
>>> Please tell me if you know any obvious optimizations? Or if you think
>>> this is due to Java (vs. C in other implementations), or any other reasons.
>>> Thank you, regards,
>>> Paul Fodor
>>> Our program has 5 rules to detect complex events:
>>> fusion.drl:
>>> rule "experiment A -Rule 0/0"
>>> when
>>> $ae1 :Event(symbol == 1, $Pr1 : price) and
>>> $ce1 :Event(this after $ae1 , symbol == 1, price > ($Pr1/1.2) )
>>> then
>>> //System.out.println("Ce1 fired !");
>>> end
>>> rule "experiment A -Rule 0/1"
>>> when
>>> (
>>> $ae2 :Event(symbol == 2,$Pr2 : price) and
>>> $ce2 : Event(this after $ae2 , symbol == 2,price > ($Pr2/1.2) )
>>> )
>>> then
>>> //System.out.println("Ce2 fired !");
>>> end
>>> rule "experiment A -Rule1"
>>> when
>>> (
>>> $ae1 :Event(symbol == 1, $Pr1 : price) and
>>> $ce1 :Event(this after $ae1 , symbol == 1, price > ($Pr1/1.2) )
>>> )
>>> or
>>> (
>>> $ae2 :Event(symbol == 2,$Pr2 : price) and
>>> $ce2 : Event(this after $ae2 , symbol == 2,price > ($Pr2/1.2) )
>>> )
>>> then
>>> //System.out.println("Ce3 fired !");
>>> end
>>>
>>> rule "experiment A -Rule4"
>>> when
>>> (
>>> $ae1 :Event(symbol == 1, $Pr1 : price) and
>>> $ce1 :Event(this after $ae1 , symbol == 1, price > ($Pr1/1.2) )
>>> )
>>> and
>>> (
>>> $ae2 :Event(symbol == 2,$Pr2 : price) and
>>> $ce2 : Event(this after $ae2 , symbol == 2,price > ($Pr2/1.2) , this
>>> after[0,20m] $ce1 )
>>> )
>>> then
>>> //System.out.println("Ce4 fired !");
>>> end
>>>
>>> rule "experiment A -Rule5"
>>> when
>>> (
>>> $ae1 :Event(symbol == 1, $Pr1 : price) and
>>> $ce1 :Event(this after $ae1 , symbol == 1, price > ($Pr1/1.2))
>>> )
>>> and
>>> (
>>> $ae2 :Event(symbol == 2,$Pr2 : price) and
>>> $ce2 : Event(this after $ae2 , symbol == 2,price > ($Pr2/1.2) , this
>>> overlaps $ce1)
>>> )
>>> then
>>> //System.out.println("Ce5 fired !");
>>> end
>>>
>>> We have an Event class for events with its parameters and an EventStream
>>> class to fire the events:
>>> EventStream.java:
>>> ...
>>> import org.drools.runtime.StatefulKnowledgeSession;
>>> public class EventStream {
>>> public StatefulKnowledgeSession get_working_session() { return
>>> ksession;}
>>> ...
>>> void generateEventStream(double duration, double p) {
>>> ...
>>> //Drools
>>> Event temp = new Event(symbol,currValue);
>>> ksession.insert(temp);
>>> ...
>>> }
>>> }
>>>
>>>
>>> _______________________________________________
>>> rules-users mailing list
>>> rules-users(a)lists.jboss.org
>>> https://lists.jboss.org/mailman/listinfo/rules-users
>>>
>>>
>>
>>
>> --
>> - http://salaboy.wordpress.com
>> - http://www.jbug.com.ar
>> - Salatino "Salaboy" Mauricio -
>>
>> _______________________________________________
>> rules-users mailing list
>> rules-users(a)lists.jboss.org
>> https://lists.jboss.org/mailman/listinfo/rules-users
>>
>>
>
> _______________________________________________
> rules-users mailing list
> rules-users(a)lists.jboss.org
> https://lists.jboss.org/mailman/listinfo/rules-users
>
>
--
- http://salaboy.wordpress.com
- http://www.jbug.com.ar
- Salatino "Salaboy" Mauricio -
--
- http://salaboy.wordpress.com
- http://www.jbug.com.ar
- Salatino "Salaboy" Mauricio -
12:34 p.m.
Hi Mauricio,
We are using Drools Fusion. However, the classes from the example that you
mentioned in your previous post (
http://anonsvn.jboss.org/repos/labs/labs/jbossrules/trunk/drools-examples...)
are not documented in the documentation (org.drools.time.Trigger and
org.drools.time.TimerService are not mentioned in the documentation:
http://downloads.jboss.com/drools/docs/5.0.1.26597.FINAL/drools-fusion/ht...).
The events that we are creating have the role "event" and they are matched
with the rules which are written in Fusion using the temporal reasoning
enabling operators. To get the comlex events feedback (printouts), please
uncomment the "println" statements in the "then" part in the
fusion.drl
(rule file), these were commented out to get better results in the
benchmarks.
I attached the sources in this email.
BTW: We have a second question regarding aggregate functions (count, sum,
etc.). Does Drools Fusion provides any kind of aggregates over events or
these should be created separately in the .drl file (as rules)? We cannot
find anything like that in the documentation.
Regards,
Paul Fodor.
fusion.drl:
//package tests
//Check docu at
http://downloads.jboss.com/drools/docs/5.0.1.26597.FINAL/drools-expert/ht...
import Event
declare Event
@role (event)
@expires (64m)
end
/*rule Newevent_detected_debug_only
dialect "mvel"
when
$a : Event()
then
System.out.println("Event "+ $a.symbol + " has been fired !");
end*/
rule "experiment A -Rule 0/0"
when
$ae1 :Event(symbol == 1, $Pr1 : price) and
$ce1 :Event(this after $ae1 , symbol == 1, price > ($Pr1/1.2))
then
//System.out.println("Ce1 fired !");
end
rule "experiment A -Rule 0/1"
when
(
$ae2 :Event(symbol == 2,$Pr2 : price) and
$ce2 : Event(this after $ae2 , symbol == 2,price > ($Pr2/1.2) )
)
then
//System.out.println("Ce2 fired !");
end
rule "experiment A -Rule1"
when
(
$ae1 :Event(symbol == 1, $Pr1 : price) and
$ce1 :Event(this after $ae1 , symbol == 1, price > ($Pr1/1.2) )
)
or
(
$ae2 :Event(symbol == 2,$Pr2 : price) and
$ce2 : Event(this after $ae2 , symbol == 2,price > ($Pr2/1.2) )
)
then
//System.out.println("Ce3 fired !");
end
rule "experiment A -Rule4"
when
(
$ae1 :Event(symbol == 1, $Pr1 : price) and
$ce1 :Event(this after $ae1 , symbol == 1, price > ($Pr1/1.2) )
)
and
(
$ae2 :Event(symbol == 2,$Pr2 : price) and
$ce2 : Event(this after $ae2 , symbol == 2,price > ($Pr2/1.2) , this
after[0,20m] $ce1 )
)
then
//System.out.println("Ce4 fired !");
end
rule "experiment A -Rule5"
when
(
$ae1 :Event(symbol == 1, $Pr1 : price) and
$ce1 :Event(this after $ae1 , symbol == 1, price > ($Pr1/1.2))
)
and
(
$ae2 :Event(symbol == 2,$Pr2 : price) and
$ce2 : Event(this after $ae2 , symbol == 2,price > ($Pr2/1.2) , this
overlaps $ce1)
)
then
//System.out.println("Ce5 fired !");
end
5573
days inactive
5579
days old
5 comments
3 participants
participants (3)
-
Mauricio Salatino -
PF -
PF