Wie implementiert man Ausführungspläne mit Siddhi?

Question

allererst mich Beschreibung meine Anforderung lassen:

data.csv: Spalte eins ist id, Spalte zwei vlaue ist.

1,0 
2,0 
3,0 
4,86 
5,87 
6,88 
7,89 
8,86 
9,0 
10,0 
11,0 
12,0 
13,0 
14,86 
15,87 
16,88 
17,89 
18,0 
19,0 
20,0 

hier ist mein Input und meine Output:

id int,value int 

data.csv fügt in Input von Event-Stream-Simulator verwenden.

Wenn fünf aufeinanderfolgende Werte> = 85 sind, würde ich die erste ID, Wert in OutPutStream aufzeichnen. Zum Beispiel werde ich ID = 4, Wert = 86, aber ID = 14 bis ID = 17 aufzeichnen, ich werde es ignorieren.

Also, wie kann ich Siddhi-Skript in Ausführungspläne schreiben, um es zu implementieren?

============================================== ============================

data2.csv:

1,0 
2,0 
3,0 
4,86 
5,87 
6,88 
7,89 
8,86 
9,87 
10,88 
11,89 
12,90 
13,91 
14,86 
15,87 
16,88 
17,89 
18,90 
19,90 
20,90 
21,0 
22,0, 
23,87 
24,85 
25,86 
26,0 
27,17 
... 
200,91 
201,0 

Answer 1

genau fünf aufeinanderfolgende Werte> = 85

from every a1=InputStream[value>=85], a2=InputStream[value>=85]+, a3=InputStream[value<85] 
select a1.id, a1.value 
having (not (a2[3] is null)) and (a2[4] is null) 
insert into OutPutStream; 

Seit mehr als fünf aufeinanderfolgende Werte> = 85

from every a1=InputStream[value>=85], a2=InputStream[value>=85]+, a3=InputStream[value<85] 
select a1.id, a1.value 
having (not (a2[3] is null)) 
insert into OutPutStream; 

Answer 2

from every a1=InputStream[value>=85], a1=InputStream[value>=85]<4> 
select a1.id, a1.value 
insert into OutPutStream; 

Sollte funktionieren !