Date: Fri, 29 Mar 2024 11:09:07 +0100 (CET) Message-ID: <1024469226.151.1711706947796@vmisdata19.uni-oldenburg.de> Subject: Exported From Confluence MIME-Version: 1.0 Content-Type: multipart/related; boundary="----=_Part_150_503018670.1711706947795" ------=_Part_150_503018670.1711706947795 Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable Content-Location: file:///C:/exported.html
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 examples s05 and s08). If the type of the s= ource is not set or wrong it can be set using the Rename Operator. The parameter heartbeatrate defines h= ow often a heartbeat should be generated if an element is processed but did= n't yield a processing result.
heartbeatrate: The rate to generate heartbeats if an element was =
processed without given a result.
query (required): The SASE+ query
OneMatchPerInstance
schema (required): The output schema of the created event (see Access Operator for an exam=
ple)
type (required): The type of the created event
#PARSER= PQL #RUNQUERY out =3D SASE({ query =3D 'PATTERN SEQ(person p, bid b) WHERE skip_till_next_match(p,b)= {p.id =3D b.bidder, b.price > 200} RETURN p.id, p.name, b.price', schema=3D[['id','Integer'],['name','String'],['price','double']], type=3D'PersonEvent1' } , person, bid )