...
| Code Block | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
SELECT auction_id * 5, sqrt(auction_id) FROM input |
SASE
Description
This operator allows to define temporal pattern to match against the stream. For this purpose we use the SASE+ query language. The query is expressed in the parameter query. The used source has to be of the correct type (for the example s05 and s08). The order is not important. If the type of the source is not set or wrong it can be set using the Rename Operator.
Dieser Operator ermöglicht es, Anfragen mit zeitlichen Mustern zu definieren. Zu diesem Zweck wird die SASE+ Anfragesprache verwendet und die Anfrage im Parameter query übergeben. Die angebenen Quellen müssen den passenden Typ 
haben (für das folgende Beispiel also s05 und s08), die Reihenfolge ist egal. Ggf. muss der Typ einer Quelle vorher noch mit Hilfe der Rename-Operation definiert werden. Der Parameter heartbeatrate legt fest, wie oft ein Hearbeat generiert werden soll, wenn ein Element verarbeitet wurde, welches aber nicht zu einem Ergebnis geführt hat.
Parameter
heartbeatrate: The rate to generate heartbeats if an element was processed without given a result.query: The SASE+ queryOneMatchPerInstance
Example
| Code Block | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
s05 = RENAME({type='s05', aliases = ['ts', 'edge']},...) |
...
PATTERNDETECT({heartbeatrate=1,query='PATTERN SEQ(s05 s1, s08 s2) |
...
where skip_till_any_match(s1,s2){ |
...
s1.edge=s2.edge } |
...
return s1.ts,s2.ts'}, s05, s08) |
PROJECT
Description
Parameter
...