filter
Filter records
Filter records
Properties
| Name | Type | Description | Required |
|---|---|---|---|
| expression | string |
Expression |
yes |
| language | string |
Language Enum: "jmespath", "sql" |
yes |
| cache | object |
Cache the result of the filter expression. See cache for the property list. Flink processor only. |
no |
Additional Properties: not allowed
Example
source:
schema: dbo
table: emp
transform:
- uses: filter
with:
language: sql
expression: age>20