E-MapReduce (EMR) Trino には、事前設定済みの組み込みコネクタが付属しており、プレースホルダーコネクタスロットを介してカスタムコネクタを追加できます。このトピックでは、利用可能な組み込みコネクタ、その設定の変更方法、およびカスタムコネクタの追加方法について説明します。
組み込みコネクタ
EMR Trino には、次の組み込みコネクタが含まれています：
| コネクタ | 説明 | リファレンス |
|---|---|---|
| Hive | Hive データウェアハウスのデータをクエリします。 | Hive コネクタ |
| Kudu | Kudu のデータのクエリ、挿入、削除を行います。 | Kudu コネクタ |
| MySQL | 外部 MySQL インスタンスのテーブルをクエリし、テーブルを作成します。 | MySQL コネクタ |
| Iceberg | Iceberg フォーマットのデータファイルをクエリします。 | Iceberg コネクタ |
| Hudi | Copy on Write (COW) および Merge on Read (MOR) テーブルのデータをクエリします。 | Hudi コネクタ |
| Delta | Delta Lake テーブルのデータをクエリします。 | Delta コネクタ |
| JMX | システムモニタリングとデバッグを実行します。 | JMX コネクタ |
| system | 基本的なクラスター情報とメトリックをクエリします。設定は不要で、すべてのデータは system ディレクトリからアクセスできます。 |
— |
組み込みコネクタの変更
各組み込みコネクタには、Trino サービスに専用の設定ファイルがあります。次の表は、コネクタと設定ファイルのマッピングを示しています：
| コネクタ | 設定ファイル |
|---|---|
| Hive | hive.properties |
| Kudu | kudu.properties |
| MySQL | mysql.properties |
| Iceberg | iceberg.properties |
| Hudi | hudi.properties |
| Delta | delta.properties |
| JMX | jmx.properties |
| system | system.properties |
次の例では、Hive コネクタの設定を変更する方法を説明します。
-
EMR コンソールで Trino サービスのページに移動し、[設定] タブをクリックしてから、[hive.properties] タブをクリックします。
-
要件に基づいて設定項目を変更します。設定項目の編集の詳細については、「設定項目の管理」をご参照ください。
-
設定を保存し、[サービス] タブの右上隅にある [その他] > [再起動] を選択します。
サービスが再起動されると、コネクタが利用可能になります。
カスタムコネクタの追加
EMR Trino は、カスタムコネクタを追加するために、connector1 から connector5 までの 5 つのプレースホルダーコネクタスロットを提供します。各スロットには、対応する設定ファイル (connector1.properties から connector5.properties まで) があります。プレースホルダーコネクタの設定は、組み込みコネクタの変更と同じ手順で行います。
前提条件
開始する前に、次のものがあることを確認してください。
-
EMR V3.27.0、EMR V4.3.0、EMR V5.2.0、またはそれ以降のマイナーバージョン
カスタムコネクタの追加
カスタムコネクタを追加するには、未使用のプレースホルダーコネクタスロットを設定します。
次の例では、connector1 スロットを使用して MongoDB コネクタを追加します。
-
EMR コンソールで Trino サービスのページに移動し、[設定] タブをクリックしてから、[connector1.properties] タブをクリックします。
-
connector.name を mongodb に設定します。
-
ビジネス要件に基づいてカスタム設定項目を追加します。設定項目の追加手順については、「設定項目の変更」をご参照ください。
-
設定を保存し、[サービス] タブの右上隅にある [その他] > [再起動] を選択します。
サービスが再起動されると、コネクタが利用可能になります。