Trino — distribuovaný SQL engine pro federované dotazy

Trino ermöglicht die Abfrage von Daten aus verschiedenen Quellen mit einem einzigen SQL-Query. Postgres, S3, Kafka — alles verbunden.

Ein SQL für alle Daten¶

Föderation — ein Query kombiniert PostgreSQL, S3 und Kafka.

SELECT c.customer_name, o.total_revenue
FROM postgres.public.customers c
JOIN (
    SELECT customer_id, SUM(total_czk) AS total_revenue
    FROM datalake.analytics.fact_orders
    WHERE order_date >= DATE '2026-01-01'
    GROUP BY customer_id
) o ON c.id = o.customer_id
WHERE c.segment = 'enterprise';

Konnektoren¶

# catalog/postgres.properties
connector.name=postgresql
connection-url=jdbc:postgresql://db:5432/app

# catalog/datalake.properties
connector.name=iceberg
hive.metastore.uri=thrift://metastore:9083

Optimierung¶

• Predicate Pushdown
• Dynamic Filtering
• Cost-Based Optimizer

Zusammenfassung¶

Trino ist ideal für föderierte Abfragen. Eine SQL-Engine für die gesamte Infrastruktur ohne Datenverschiebung.