MaxCompute:Java で UDF を開発する

MaxCompute Studio の使用

この例では、MaxCompute Studio を使用して文字列を小文字に変換する Java UDF を開発および呼び出す方法を示します。

1. 環境を準備します。

   MaxCompute Studio で UDF を開発およびデバッグする前に、MaxCompute Studio をインストールし、MaxCompute プロジェクトに接続する必要があります。詳細については、以下をご参照ください。

   1. MaxCompute Studio のインストール

   2. MaxCompute プロジェクトへの接続

   3. MaxCompute Java モジュールの作成

2. UDF コードを記述します。

   1. Project ビューで、モジュールのソースコードディレクトリ（src > main > java）を右クリックし、New > MaxCompute Java を選択します。

   2. Create new MaxCompute java class ダイアログボックスで、UDF をクリックし、Name に名前を入力して Enter キーを押します。

      

      Name は MaxCompute Java クラスの名前です。パッケージを作成していない場合は、packagename.classname と入力すると自動的に作成されます。この例では、Java クラス名を Lower とします。

   3. エディターで UDF コードを記述します。 以下のコードがその例です。

      package com.aliyun.odps.udf.example;
      import com.aliyun.odps.udf.UDF;
      public final class Lower extends UDF {
          public String evaluate(String s) {
              if (s == null) { 
                 return null; 
              }
                 return s.toLowerCase();
          }
      }

      説明

      Java UDF をローカルでデバッグする方法については、「UDF の開発およびデバッグ」をご参照ください。

3. UDF をアップロードおよび登録します。

   UDF Java ファイルを右クリックし、Deploy to server... を選択します。Package a jar, submit resource and register function ダイアログボックスでパラメーターを設定し、OK をクリックします。

   • MaxCompute project：UDF を登録する MaxCompute プロジェクト。

   • Resource file：UDF が依存するリソースファイルのパス。

   • Resource name：MaxCompute 内での UDF の JAR ファイルリソース名。

   • Function name：登録される関数の名前。これは SQL ステートメントで使用する UDF 名です（例：Lower_test）。

4. UDF をデバッグします。

   左側のナビゲーションウィンドウで Project Explore をクリックします。対象の MaxCompute プロジェクトを右クリックし、Open Console を選択します。次に、UDF を呼び出す SQL ステートメントを入力し、Enter キーを押して実行します。 以下の SQL ステートメントがその例です。

   select lower_test('ABC');

   以下の結果が返されます。

   +-----+
   | _c0 |
   +-----+
   | abc |
   +-----+

DataWorks の使用

1. 環境を準備します。

   DataWorks で UDF を開発およびデバッグする前に、DataWorks を有効化し、DataWorks ワークスペースを MaxCompute プロジェクトに関連付ける必要があります。詳細については、「DataWorks からの MaxCompute 接続」をご参照ください。

2. UDF コードを記述します。

   任意の Java 開発ツールで UDF コードを開発し、JAR ファイルにパッケージ化できます。以下のコードがその例です。

   package com.aliyun.odps.udf.example;
   import com.aliyun.odps.udf.UDF;
   public final class Lower extends UDF {
       public String evaluate(String s) {
           if (s == null) { 
              return null; 
           }
              return s.toLowerCase();
       }
   }

3. UDF をアップロードおよび登録します。

   パッケージ化されたコードを DataWorks にアップロードし、UDF を登録できます。詳細については、以下をご参照ください。

   1. MaxCompute リソースの作成および使用

   2. MaxCompute 関数の作成および使用

4. UDF をデバッグします。

   UDF を登録後、ODPS SQL ノードを作成します。ノード内で SQL コマンドを記述・実行して UDF をデバッグします。ODPS SQL ノードの作成方法については、「ODPS SQL ノードの作成」をご参照ください。以下はデバッグコマンドの例です。

   select lower_test('ABC');

odpscmd の使用

1. 環境を準備します。

   MaxCompute クライアント (odpscmd) を使用して UDF を開発およびデバッグする前に、クライアントをダウンロードしてインストールします。次に、設定ファイルを構成して、MaxCompute プロジェクトに接続します。詳細については、「MaxCompute クライアント (odpscmd) を使用して MaxCompute に接続する」をご参照ください。

2. UDF コードを記述します。

   任意の Java 開発ツールで UDF コードを開発し、JAR ファイルにパッケージ化できます。以下のコードがその例です。

   package com.aliyun.odps.udf.example;
   import com.aliyun.odps.udf.UDF;
   public final class Lower extends UDF {
       public String evaluate(String s) {
           if (s == null) { 
              return null; 
           }
              return s.toLowerCase();
       }
   }

3. UDF をアップロードおよび登録します。

   MaxCompute クライアント（odpscmd）を使用してパッケージ化されたコードをアップロードし、UDF を登録できます。詳細については、以下をご参照ください。

   1. ADD JAR

   2. CREATE FUNCTION

4. UDF をデバッグします。

   UDF を登録後、SQL コマンドを記述・実行して UDF をデバッグできます。以下はデバッグコマンドの例です。

   select lower_test('ABC');