The select operator filters the incoming data stream according to the given predicate.
Parameter
predicate:
The predicate to evaluate over each incoming tuple
Example
PQL
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
output = SELECT({ predicate='price > 100' }, input) |
CQL
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
SELECT * FROM input WHERE price > 100 |