Source
yaml
id: trino-query
namespace: company.team
tasks:
- id: analyze_orders
type: io.kestra.plugin.jdbc.trino.Query
url: jdbc:trino://host.docker.internal:8090/tpch
username: trino
sql: |
select orderpriority as priority, sum(totalprice) as total
from tpch.tiny.orders
group by orderpriority
order by orderpriority
fetchType: STORE
- id: csv_report
type: io.kestra.plugin.serdes.csv.IonToCsv
from: "{{ outputs.analyze_orders.uri }}"
About this blueprint
SQL Outputs
This flow queries data using Trino SQL and generates a downloadable CSV report.
To test this integration, you can start Trino in a Docker container:
bash docker run -d -p 8090:8080 --name trino trinodb/trino
More Related Blueprints