Delta Lake カタログ

Delta Lake カタログはTrino Connector互換性フレームワークを使用して、Delta Lake Connectorを通じてDelta Lakeテーブルにアクセスします。

注記

この機能は実験的であり、バージョン3.0.1以降でサポートされています。

適用シナリオ

シナリオ	説明
データ統合	Delta Lakeデータを読み込み、Doris内部テーブルに書き込みます。
データライトバック	サポートされていません。

環境準備

Delta Lake Connectorプラグインのコンパイル

JDK 17が必要です。

$ git clone https://github.com/apache/doris-thirdparty.git
$ cd doris-thirdparty
$ git checkout trino-435
$ cd plugin/trino-delta-lake
$ mvn clean install -DskipTests
$ cd ../../lib/trino-hdfs
$ mvn clean install -DskipTests

コンパイル後、trino/plugin/trino-delta-lake/target/の下にtrino-delta-lake-435ディレクトリが、trino/lib/trino-hdfs/target/の下にhdfsディレクトリが見つかります。

また、事前にコンパイルされたtrino-delta-lake-435-20240724.tar.gzとhdfs.tar.gzを直接ダウンロードして展開することもできます。

Delta Lake Connectorのデプロイ

すべてのFEおよびBEデプロイメントパスのconnectors/ディレクトリにtrino-delta-lake-435/ディレクトリを配置し（存在しない場合は手動で作成できます）、hdfs.tar.gzをtrino-delta-lake-435/ディレクトリに展開します。

├── bin
├── conf
├── connectors
│   ├── trino-delta-lake-435
│   │   ├── hdfs
...

デプロイ後、Connectorが正しくロードされることを確実にするため、FEおよびBEノードを再起動することを推奨します。

Catalogの設定

構文

CREATE CATALOG [IF NOT EXISTS] catalog_name
PROPERTIES (
    'type' = 'trino-connector', -- required
    'trino.connector.name' = 'delta_lake', -- required
    {TrinoProperties},
    {CommonProperties}
);

• {TrinoProperties}

  TrinoPropertiesセクションは、Trino Connectorに渡されるプロパティを指定するために使用されます。これらのプロパティは trino. プレフィックスを使用します。理論的には、Trinoでサポートされているすべてのプロパティがここでもサポートされています。Delta Lakeの詳細については、Trino documentationを参照してください。

• [CommonProperties]

  CommonPropertiesセクションは、一般的なプロパティを指定するために使用されます。「Common Properties」セクションのCatalog Overviewを参照してください。

サポートされているDelta Lakeバージョン

Delta Lakeの詳細については、Trino documentationを参照してください。

サポートされているMetadataサービス

Delta Lakeの詳細については、Trino documentationを参照してください。

サポートされているStorageシステム

Delta Lakeの詳細については、Trino documentationを参照してください。

カラム型マッピング

Delta Lake Type	Trino Type	Doris Type	Comment
boolean	boolean	boolean
int	int	int
byte	tinyint	tinyint
short	smallint	smallint
long	bigint	bigint
float	real	float
double	double	double
decimal(P, S)	decimal(P, S)	decimal(P, S)
string	varchar	string
bianry	varbinary	string
date	date	date
timestamp_ntz	timestamp(N)	datetime(N)
timestamp	timestamp with time zone(N)	datetime(N)
array	array	array
map	map	map
struct	row	struct

例

CREATE CATALOG delta_lake_hms properties ( 
    'type' = 'trino-connector', 
    'trino.connector.name' = 'delta_lake',
    'trino.hive.metastore' = 'thrift',
    'trino.hive.metastore.uri'= 'thrift://ip:port',
    'trino.hive.config.resources'='/path/to/core-site.xml,/path/to/hdfs-site.xml'
);

クエリ操作

Catalogを設定した後、以下の方法を使用してCatalog内のテーブルデータをクエリできます：

-- 1. Switch to the catalog, use the database, and query
SWITCH delta_lake_ctl;
USE delta_lake_db;
SELECT * FROM delta_lake_tbl LIMIT 10;

-- 2. Use the Delta Lake database directly
USE delta_lake_ctl.delta_lake_db;
SELECT * FROM delta_lake_tbl LIMIT 10;

-- 3. Use the fully qualified name to query
SELECT * FROM delta_lake_ctl.delta_lake_db.delta_lake_tbl LIMIT 10;