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
RATE THIS PAGE
Back to top ↑