組み込みカタログタイプがニーズを満たさない場合は、カスタムカタログを作成できます。このトピックでは、カスタムカタログの作成方法と設定方法について説明します。
注意事項
-
カスタムカタログタイプの名前は一意にする必要があります。
カスタムカタログタイプが組み込みカタログタイプと同じ名前の場合、カスタムカタログタイプが優先されます。
-
カスタムカタログタイプを削除すると、そのタイプのすべてのカタログも削除されます。
カスタムカタログの作成と使用
-
[Catalogs] ページに移動します。
-
対象のワークスペースの [Actions] 列で、[Console] をクリックします。
-
左側のナビゲーションウィンドウで、[Catalogs] をクリックします。
-
[Create Catalog] をクリックします。[Custom Catalog] タブで、[Add Catalog Type] をクリックします。
-
[Create catalog type] ダイアログボックスで、カスタムカタログタイプを設定します。
方法
説明
[ファイルのアップロード]
[Select File] をクリックして、カスタムカタログタイプのファイルを選択します。カスタムカタログタイプの開発方法の詳細については、「catalogs」をご参照ください。
[外部 URL]
[External URL] を入力します。この方法で、別のサービスから JAR ファイルを取得できます。
説明サポートされている外部 URL は、次の 2 種類のみです。
Flink ワークスペースの作成時に選択した OSS バケットの URL。アタッチされた OSS バケットは、Realtime Compute for Apache Flink コンソール の [ワークスペース詳細] ページで確認できます。
Realtime Compute for Apache Flink がアクセス権限 (公開読み取りまたは付与された権限) を持つ別の外部ストレージシステムの URL。
-
[Next] をクリックします。
-
プロパティを確認し、[OK] をクリックします。
[パラメーター設定] ステップで、[カタログタイプ] を hologres-new に設定すると、プロパティリストが自動的に入力されます。このリストには、
poolsize(デフォルト:10)、async(デフォルト:false)、password(必須)、jdbcretrysleeptime(デフォルト:1000)、jdbcscanfetchsize(デフォルト:256) などのプロパティが含まれます。[Add Property] をクリックしてプロパティを追加するか、削除アイコンをクリックして削除できます。 -
[Custom Catalog] タブで、先ほど作成したカスタムカタログタイプをクリックし、[Next] をクリックします。
-
カタログコードとパラメーター値を入力し、[OK] をクリックしてカタログを作成します。
次のコードは一例です。要件に応じて変更できます。
CREATE CATALOG `catalogname` -- 作成するカタログの名前。 WITH ( 'type' = 'hologres-custom', -- ステップ 3 で作成したカタログタイプの名前。 'endpoint' = 'yourEndpoint', -- ステップ 5 で必須と指定したパラメーターは、WITH 句に含める必要があります。以降のパラメーターも同様です。 'username' = 'yourUsername', 'password' = 'yourPassword', 'dbname' = 'yourDbname' );説明カタログ名はバッククォート () で囲みます。囲まない場合、名前がピリオド (
.) などの特殊文字を含んでいるとエラーが発生します。
カスタムカタログタイプの表示または削除
-
[Catalogs] ページで、[Create Catalog] をクリックします。
-
[Custom Catalog] タブをクリックして、カスタムカタログタイプを表示または削除します。
-
表示:カスタムカタログタイプにカーソルを合わせると、JAR パッケージパス、カタログタイプ、作成時刻、作成者などの詳細が表示されます。
-
削除:対象のカスタムカタログタイプの横にある
アイコンをクリックし、[OK] をクリックします。
-
関連トピック
-
Realtime Compute for Apache Flink は、さまざまな組み込みカタログタイプを提供しています。詳細については、「catalogs」をご参照ください。
-
サポートされているコネクタのリストについては、「サポートされているコネクタ」をご参照ください。