Druid connector

{raw}

The Druid connector allows querying an Apache Druid database from Trino.

Requirements

To connect to Druid, you need:

Druid version 0.18.0 or higher.
Network access from the Trino coordinator and workers to your Druid broker. Port 8082 is the default port.

Configuration

Create a catalog properties file that specifies the Druid connector by setting the connector.name to druid and configuring the connection-url with the JDBC string to connect to Druid.

For example, to access a database as example, create the file etc/catalog/example.properties. Replace BROKER:8082 with the correct host and port of your Druid broker.

properties

connector.name=druid
connection-url=jdbc:avatica:remote:url=http://BROKER:8082/druid/v2/sql/avatica/

You can add authentication details to connect to a Druid deployment that is secured by basic authentication by updating the URL and adding credentials:

properties

connection-url=jdbc:avatica:remote:url=http://BROKER:port/druid/v2/sql/avatica/;authentication=BASIC
connection-user=root
connection-password=secret

Now you can access your Druid database in Trino with the example catalog name from the properties file.

The connection-user and connection-password are typically required and determine the user credentials for the connection, often a service user. You can use {doc}secrets </security/secrets> to avoid actual values in the catalog properties files.

{include}

(druid-type-mapping)=

Type mapping

Because Trino and Druid each support types that the other does not, this connector {ref}modifies some types <type-mapping-overview> when reading data.

Druid type to Trino type mapping

The connector maps Druid types to the corresponding Trino types according to the following table:

:::{list-table} Druid type to Trino type mapping :widths: 30, 30, 50 :header-rows: 1

- Druid type
- Trino type
- Notes
- STRING
- VARCHAR
- FLOAT
- REAL
- DOUBLE
- DOUBLE
- LONG
- BIGINT
- Except for the special _time column, which is mapped to TIMESTAMP.
- TIMESTAMP
- TIMESTAMP
- Only applicable to the special _time column. :::

No other data types are supported.

Druid does not have a real NULL value for any data type. By default, Druid treats NULL as the default value for a data type. For example, LONG would be 0, DOUBLE would be 0.0, STRING would be an empty string '', and so forth.

{include}

(druid-sql-support)=

SQL support

The connector provides read access to data and metadata in the Druid database. In addition to the globally available and read operation statements, the connector supports the following features:

(druid-procedures)=

Procedures

{include}

(druid-table-functions)=

Table functions

The connector provides specific {doc}table functions </functions/table> to access Druid.

(druid-query-function)=

`query(varchar) -> table`

The query function allows you to query the underlying database directly. It requires syntax native to Druid, because the full query is pushed down and processed in Druid. This can be useful for accessing native features which are not available in Trino or for improving query performance in situations where running a query natively may be faster.

{include}

As an example, query the example catalog and use STRING_TO_MV and MV_LENGTH from Druid SQL's multi-value string functions to split and then count the number of comma-separated values in a column:

SELECT
  num_reports
FROM
  TABLE(
    example.system.query(
      query => 'SELECT
        MV_LENGTH(
          STRING_TO_MV(direct_reports, ",")
        ) AS num_reports
      FROM company.managers'
    )
  );

{include}