Select
Align, filter, and project records
Select
Align, filter, and project records
yaml
type: io.kestra.plugin.transform.SelectExamples
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
inputs *RequiredNon-dynamicarray
dropNulls booleanstring
Default
truefields object
Definitions
io.kestra.plugin.transform.Select-FieldDefinition
exprstring
optionalboolean
Default
falsetypestring
Possible Values
STRINGINTFLOATDECIMALBOOLEANTIMESTAMPLISTSTRUCTkeepInputFields array
SubTypeinteger
Default
[]onError string
Default
FAILPossible Values
FAILSKIPKEEPonLengthMismatch string
Default
FAILPossible Values
FAILSKIPoutputFormat string
Default
TEXTPossible Values
TEXTBINARYoutputType string
Default
AUTOPossible Values
AUTORECORDSSTORE