Trino Connectors
Trino connectors provide the interface between Trino and external data sources. Each connector implements data source-specific protocols for metadata discovery, predicate pushdown, and data retrieval. The MATIH platform includes a curated set of connectors for common data sources.
Built-In Connectors
| Connector | Source Type | Description |
|---|---|---|
delta_lake | Object Storage | Reads Delta Lake tables from S3/MinIO |
iceberg | Object Storage | Reads Apache Iceberg tables |
hive | Object Storage | Reads Hive-compatible tables (Parquet, ORC, Avro) |
postgresql | RDBMS | Connects to PostgreSQL databases |
mysql | RDBMS | Connects to MySQL databases |
sqlserver | RDBMS | Connects to SQL Server databases |
mongodb | Document Store | Connects to MongoDB collections |
elasticsearch | Search Engine | Queries Elasticsearch indices |
kafka | Streaming | Reads from Kafka topics as tables |
memory | In-Memory | Temporary in-memory tables |
system | Internal | Trino system metadata |
Connector Capabilities
| Connector | Predicate Pushdown | Projection Pushdown | Aggregation Pushdown | Write Support |
|---|---|---|---|---|
delta_lake | Yes | Yes | Partial | Yes |
iceberg | Yes | Yes | Partial | Yes |
postgresql | Yes | Yes | Yes | Yes |
mysql | Yes | Yes | Partial | Yes |
mongodb | Partial | Yes | No | No |
elasticsearch | Partial | Yes | Partial | No |
kafka | No | Yes | No | No |
Adding a Connector
Custom connectors are added by creating a properties file in the Trino catalog directory:
# mydb.properties
connector.name=postgresql
connection-url=jdbc:postgresql://host:5432/database
connection-user=${DB_USER}
connection-password=${DB_PASSWORD}Credentials must be provided via Kubernetes secrets, not hardcoded in properties files.
Connector-Specific Configuration
Delta Lake
| Property | Description |
|---|---|
hive.metastore.uri | Hive metastore Thrift URI |
delta.metadata.cache-ttl | Metadata cache duration |
hive.s3.endpoint | S3-compatible storage endpoint |
PostgreSQL / MySQL
| Property | Description |
|---|---|
connection-url | JDBC connection URL |
connection-user | Database username (from secret) |
connection-password | Database password (from secret) |
Kafka
| Property | Description |
|---|---|
kafka.nodes | Kafka bootstrap servers |
kafka.table-names | Topics to expose as tables |
kafka.default-schema | Default schema name |
Connector Health
The Query Engine monitors connector health through Trino's catalog listing API. Failed connectors are flagged in the platform status dashboard and excluded from query routing decisions.