このトピックでは、E-MapReduce(EMR)のTrinoによって提供される組み込みコネクタについて説明します。 また、EMRコンソールでコネクタの設定を変更し、カスタムコネクタを追加する方法についても説明します。
EMR Trinoの組み込みコネクタ
次の表に、EMR Trinoによって提供されるすぐに使用できる組み込みコネクタを示します。
コネクタ | 説明 | 参照 |
Hive | このコネクタを使用して、Hiveデータウェアハウスのデータをクエリできます。 | |
Kudu | このコネクタを使用して、Kuduのデータをクエリ、挿入、および削除できます。 | |
MySQL | このコネクタを使用して、外部MySQLインスタンスのテーブルのデータをクエリし、インスタンスにテーブルを作成できます。 | |
Iceberg | このコネクタを使用して、Iceberg形式のデータファイルをクエリできます。 | |
Hudi | このコネクタを使用して、Copy on Write(COW)テーブルおよびMerge on Read(MOR)テーブルのデータをクエリできます。 | |
Delta | このコネクタを使用して、Delta Lakeテーブルのデータをクエリできます。 | |
JMX | このコネクタを使用して、システムの監視とデバッグを実行できます。 | |
system | このコネクタを使用して、Trinoクラスタの基本情報とメジャーをクエリできます。 説明
| なし |
組み込みコネクタの設定の変更
EMRコンソールの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 V3.27.0、EMR V4.3.0、EMR V5.2.0、およびそれ以降のマイナーバージョンでのみサポートされています。
デフォルトでは、EMR Trinoは、connector1、connector2、connector3、connector4、connector5を含む5つのプレースホルダーコネクタを提供します。 これらのプレースホルダーコネクタを使用して、カスタムコネクタを追加できます。 EMRコンソールのTrinoサービスページの [設定] タブに移動し、[connector1.properties] タブ、[connector2.properties] タブ、[connector3.properties] タブ、[connector4.properties] タブ、および [connector5.properties] タブでプレースホルダーコネクタを設定できます。プレースホルダーコネクタは、組み込みコネクタと同じ方法で設定されます。
カスタムコネクタを追加するには、空いているプレースホルダーコネクタの設定を変更するだけです。
例: MongoDB コネクタを追加する
EMRコンソールのTrinoサービスページに移動し、[設定] タブをクリックしてから、[connector1.properties] タブをクリックします。
connector.name 設定項目の値を mongodb に変更します。
ビジネス要件に基づいてカスタム設定項目を追加します。
カスタム設定項目の追加方法の詳細については、「設定項目の変更」をご参照ください。
設定を保存した後、[サービス]タブの右上隅にある を選択します。
説明サービスが再起動されると、コネクタが使用可能になります。