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 |