...
| Code Block |
|---|
out = SELECT({
predicate = 'price >= 400'
},
nexmark:bid
)
mail = SENDER({
sink='Sink',
wrapper='GenericPush',
transport='SMTP',
protocol='CSV',
datahandler='Tuple',
options=[
['from','alert@test.de'],
['to','receiver@test.de'],
['subject','Price Alert'],
['host','smtp.server.de'],
['tls','false']
]
},
out
) |
Pattern 3: Simple Counting and Counting with Windows
For Counting (building sum, avg, finding min, max. etc.) the Aggregate (and Group) operator can be used. See Aggregation and Window for examples on this topic.
Pattern 4: Joining Event Streams
...