Realtime Compute for Apache Flink:UDF の管理

カタログ UDF の登録

1. [UDF アーティファクトの登録] ダイアログボックスに移動します。

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

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

   3. 左側のナビゲーションペインで、[開発] > [ETL] をクリックします。

   4. SQL エディターページの左側にある [UDF] タブをクリックします。

2. [UDF アーティファクトの登録] をクリックします。

3. [UDF アーティファクトの登録] ダイアログボックスで、UDF JAR ファイルをアップロードします。

   次のいずれかの方法を使用して、UDF JAR ファイルをアップロードできます。

   • [ファイルのアップロード]：[ファイルを選択] の横にある [クリックして選択] をクリックして、アップロードする UDF JAR ファイルをアップロードします。依存関係ファイルをアップロードする場合は、[依存関係] の横にある [クリックして選択] をクリックして、UDF JAR ファイルが依存するファイルをアップロードします。

     説明

     • UDF JAR ファイルは、選択したオブジェクトストレージサービス (OSS) バケットの sql-artifacts ディレクトリにアップロードされて保存されます。

     • Java UDF の依存関係は、UDF JAR ファイルにパッケージ化することも、依存関係ファイルとして個別にアップロードすることもできます。Python UDF の場合は、依存関係を依存関係ファイルとして個別にアップロードすることをお勧めします。

   • [外部 URL]：外部 URL を入力します。別のサービスで使用されている UDF JAR ファイルを使用する場合は、外部 URL を使用して UDF ファイルを取得できます。

     説明

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

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

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

4. [確認] をクリックします。

5. [関数の管理] ダイアログボックスの [使用可能な関数] セクションで、登録する 1 つ以上の UDF を選択し、[関数の作成] をクリックします。

   フルマネージド Flink のコンソールでは、Flink は UDF JAR ファイルを解析し、ファイル内で Flink の UDF、ユーザー定義集計関数 (UDAF)、およびユーザー定義テーブル値関数 (UDTF) インターフェースのクラスが使用されているかどうかを確認します。次に、Flink はクラス名を自動的に抽出し、[関数の管理] ダイアログボックスの [関数名] 列にクラス名を入力します。UDF が登録されると、SQL エディターページの左側にある [UDF] ペインに登録したすべての UDF が表示されます。黄色で強調表示された fx 文字は、登録した各 UDF の名前の左側に表示されます。

   

   説明

   デフォルトでは、カタログ UDF を登録するときに、データ解析に最新バージョンの Realtime Compute for Apache Flink が使用されます。デプロイメントでカタログ UDF を使用し、[構成] タブの [基本] セクションで以前のエンジンバージョンの Realtime Compute for Apache Flink を選択すると、互換性の問題が発生する可能性があります。この問題を解決するには、デプロイメントで必要なエンジンバージョンに基づいて UDF コードを実装し、デプロイメントレベルの UDF を使用できます。詳細については、「デプロイメントレベルの UDF の登録」をご参照ください。

デプロイメントレベルの UDF の登録

デプロイメントレベルの UDF を登録するには、次の手順を実行します。

1. UDF の JAR または Python ファイルをアップロードします。

   左側のナビゲーションペインで、[アーティファクト] をクリックします。[アーティファクト] ページで、[アーティファクトのアップロード] をクリックして、UDF の JAR または Python ファイルをアップロードします。

2. デプロイメントでデプロイメントレベルの UDF を指定します。

   SQL エディターページの [構成] タブで、[追加の依存関係] から UDF の JAR または Python ファイルを選択します。

3. デプロイメントレベルの UDF を登録します。

   • Java UDF

     CREATE TEMPORARY FUNCTION yourfunctionname;

   • Python UDF

     CREATE TEMPORARY FUNCTION yourfunctionname LANGUAGE Python;