Select Select
Select Certified

Align, filter, and project records

yaml
type: io.kestra.plugin.transform.Select
yaml
id: select_join_inputs
namespace: company.team

tasks:
  - id: orders
    type: io.kestra.plugin.core.output.OutputValues
    values:
      records:
        - order_id: o1
          amount: 120
        - order_id: o2
          amount: 70

  - id: customers
    type: io.kestra.plugin.core.output.OutputValues
    values:
      records:
        - name: Alice
        - name: Bob

  - id: scores
    type: io.kestra.plugin.core.output.OutputValues
    values:
      records:
        - score: 0.9
        - score: 0.4

  - id: select
    type: io.kestra.plugin.transform.Select
    inputs:
      - "{{ outputs.orders.values.records }}"
      - "{{ outputs.customers.values.records }}"
      - "{{ outputs.scores.values.records }}"
    where: amount > 100 && $3.score > 0.8
    fields:
      orderId: order_id
      customer: $2.name
      amount: $1.amount
      score: $3.score
    outputType: RECORDS
Properties
Defaulttrue
Definitions
exprstring
optionalboolean
Defaultfalse
typestring
Possible Values
STRINGINTFLOATDECIMALBOOLEANTIMESTAMPLISTSTRUCT
SubTypeinteger
Default[]
DefaultFAIL
Possible Values
FAILSKIPKEEP
DefaultFAIL
Possible Values
FAILSKIP
DefaultTEXT
Possible Values
TEXTBINARY
DefaultAUTO
Possible Values
AUTORECORDSSTORE