Query

id: trino_query
namespace: company.team

tasks:
  - id: analyze_orders
    type: io.kestra.plugin.jdbc.trino.Query
    url: jdbc:trino://localhost:8080/tpch
    username: "{{ secret('TRINO_USERNAME') }}"
    password: "{{ secret('TRINO_PASSWORD') }}"
    sql: |
      select orderpriority as priority, sum(totalprice) as total
      from tpch.tiny.orders
      group by orderpriority
      order by orderpriority
    fetchType: FETCH
    fetchType: STORE

  - id: csv_report
    type: io.kestra.plugin.serdes.csv.IonToCsv
    from: "{{ outputs.analyze_orders.uri }}"