すべてのプロダクト
Search
ドキュメントセンター

Realtime Compute for Apache Flink:カスタムカタログの管理

最終更新日:Jan 08, 2025

組み込みのカタログタイプがビジネス要件を満たせない場合は、カスタムカタログタイプを使用できます。このトピックでは、カスタムカタログを設定する方法について説明します。

注意事項

  • カスタムカタログタイプの名前は、他のカスタムカタログタイプの名前と異なっている必要があります。

    カスタムカタログタイプの名前が組み込みカタログの名前と同じ場合、カスタムカタログタイプが使用されます。

  • カスタムカタログタイプを削除すると、そのカスタムカタログタイプのカタログも削除されます。

カスタムカタログの作成と使用

  1. カタログリストページに移動します。

    1. Realtime Compute for Apache Flinkコンソール にログインします。

    2. 管理するワークスペースを見つけ、[アクション] 列の [コンソール] をクリックします。

    3. 左側のナビゲーションペインで、[カタログ] をクリックします。

  2. カタログリストページで、[カタログの作成] をクリックします。 [カタログの作成] ダイアログボックスで、[カスタムカタログ] タブをクリックします。 [カスタムカタログ] タブで、[カタログタイプの追加] をクリックします。

  3. [カタログタイプの作成] ダイアログボックスで、パラメーターを設定します。次の表にパラメーターを示します。

    image

    メソッド

    説明

    ファイルのアップロード

    [クリックして選択] をクリックし、目的のカスタムカタログタイプのファイルを選択します。カスタムカタログタイプの開発方法の詳細については、「カタログ」をご参照ください。

    外部 URL の使用

    [外部 URL の使用] フィールドに情報を入力します。別のサービスの JAR ファイルを使用する場合は、この方法を使用して JAR ファイルを取得できます。

    説明

    次の 2 種類の外部 URL のみがサポートされています。

    • Realtime Compute for Apache Flink ワークスペースの購入時に指定したオブジェクトストレージサービス(OSS)バケットのエンドポイント。指定した OSS バケットのエンドポイントは、Realtime Compute for Apache Flink の管理コンソール[ワークスペースの詳細] メッセージで確認できます。

    • Realtime Compute for Apache Flink がアクセスできる別の外部ストレージシステムのエンドポイント。外部ストレージシステムのアクセス制御リスト(ACL)はパブリック読み取りであるか、Realtime Compute for Apache Flink に外部ストレージシステムへのアクセス権限が付与されています。

  4. [次へ] をクリックします。

  5. プロパティを確認し、[OK] をクリックします。

    image

  6. [カスタムカタログ] タブで、作成したカスタムカタログタイプの名前をクリックし、[次へ] をクリックします。

  7. カタログコードとパラメーター値を入力し、[OK] をクリックしてカタログを作成します。

    次のサンプルコードは例を示しています。ビジネス要件に基づいてコードを変更できます。

    CREATE CATALOG `catalogname` --catalogname は作成するカタログの名前を示します。
    WITH (
    'type'='hologres-custom',  --手順 5 で指定したカタログタイプ名。
    'endpoint' = 'yourEndpoint',  --手順 5 の [必須] 列で選択されたパラメーターは、WITH 句で設定する必要があります。
    'username' = 'yourUsername',
    'password' = 'yourPassword',
    'dbname' = 'yourDbname'
    );
    説明

    catalogname パラメーターの値をグレイブアクセント(``)で囲むことをお勧めします。そうしないと、名前にピリオド(.)が含まれるカタログを実行するとエラーが報告される場合があります。

カスタムカタログタイプの表示または削除

  1. [カタログリスト] ページで、[カタログの作成] をクリックします。

  2. [カタログの作成] ダイアログボックスで、[カスタムカタログ] タブをクリックします。 [カスタムカタログ] タブで、カスタムカタログタイプを表示または削除します。

    • カスタムカタログタイプの情報を表示するには、目的のカスタムカタログタイプの名前の上にポインターを移動します。 JAR パッケージパス、カタログタイプ、作成時刻、作成者などの情報が表示されます。

    • カスタムカタログタイプを削除するには、カスタムカタログタイプの名前の横にある image アイコンをクリックします。表示されるメッセージで、[確認] をクリックします。

参照

  • Realtime Compute for Apache Flink でサポートされている組み込みカタログタイプの詳細については、「カタログの管理」をご参照ください。

  • Realtime Compute for Apache Flink でサポートされているコネクターの詳細については、「サポートされているコネクター」をご参照ください。