E-MapReduce (EMR) には、組み込みの Trino コネクタが用意されており、カスタムコネクタで変更または拡張できます。
EMR の組み込み Trino コネクタ
EMR Trino には、以下の組み込みコネクタが含まれています。
|
コネクタ |
説明 |
参照先 |
|
Hive |
Hive コネクタを使用すると、Hive データウェアハウス内のデータをクエリできます。 |
|
|
Kudu |
Kudu コネクタを使用すると、Kudu 内のデータをクエリ、挿入、および削除できます。 |
|
|
MySQL |
MySQL コネクタを使用すると、外部の MySQL インスタンス内のテーブルをクエリおよび作成できます。 |
|
|
Iceberg |
Iceberg コネクタを使用すると、Iceberg フォーマットのデータファイルをクエリできます。 |
|
|
Hudi |
Hudi コネクタを使用すると、Copy on Write (CoW) テーブルおよび Merge on Read (MoR) テーブルをクエリできます。 |
|
|
Delta |
Delta コネクタを使用すると、Delta Lake テーブルをクエリできます。 |
|
|
JMX |
JMX コネクタは、システムのモニタリングおよびデバッグを有効にします。 |
|
|
system |
system コネクタを使用すると、クラスター情報およびメトリックをクエリできます。 説明
system コネクタには設定は不要です。すべての情報は |
なし |
組み込みコネクタの変更
EMR コンソールの Trino サービスの Configure タブで、各コネクタの設定ファイルを変更できます。次の表は、各コネクタとその設定ファイルの対応関係を示しています。
|
コネクタ |
設定ファイル |
|
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 サービスの Configure タブで、Service Configuration セクションの hive.properties タブをクリックします。
-
必要に応じて設定項目を変更します。
詳細については、「設定項目の管理」をご参照ください。
-
設定を保存した後、右上隅の を選択します。
説明サービスが再起動すると、コネクタが使用可能になります。
カスタムコネクタの追加
この機能は、EMR V3.27.0、V4.3.0、V5.2.0 以降のバージョンでのみ利用可能です。
デフォルトでは、EMR Trino にカスタム用途向けのプレースホルダーコネクタが 5 つ用意されています（connector1 ～ connector5）。これらは、Trino サービスの Configure タブにある connector1.properties、connector2.properties、connector3.properties、connector4.properties、および connector5.properties ファイルに対応しています。設定手順は組み込みコネクタと同じです。
カスタムコネクタを追加するには、未使用のプレースホルダーコネクタの設定を変更します。
例：MongoDB コネクタの追加
-
EMR コンソールの Trino サービスの Configure タブで、Service Configuration セクションの connector1.properties タブをクリックします。
-
connector.name を mongodb に設定します。
-
必要に応じてカスタム設定項目を追加します。
詳細については、「設定項目の変更」をご参照ください。
-
設定を保存した後、右上隅の を選択します。
説明サービスが再起動すると、コネクタが使用可能になります。