MaxCompute:IntelliJ IDEA を使用した Java UDF の開発

操作手順

1. Java で UDF を作成します。

   1. 左側のナビゲーションウィンドウで、[Project] タブをクリックします。src > main > java を展開し、java を右クリックして、[New] > [MaxCompute Java] を選択します。

      

   2. [Create new MaxCompute java class] ダイアログボックスで、[UDF] をクリックします。[Name] フィールドにクラスの名前を入力し、Enter キーを押します。

      

      [Name] は、作成する MaxCompute Java クラスの名前を指定します。パッケージを作成していない場合は、packagename.classname と入力してパッケージを自動的に生成できます。

      注：パッケージを作成していない場合は、packagename.classname のフォーマットで名前を入力します。システムによってパッケージが自動的に生成されます。

   3. 生成された Java ファイルに、UDF ロジックを実装します。次の例は、文字列を小文字に変換する UDF を示しています。

      

      package <packagename>;
      import com.aliyun.odps.udf.UDF;          // すべての MaxCompute UDF に必要な基底クラス
      
      public final class Lower extends UDF {   // スカラー関数の場合は UDF を継承する必要があります
      
          // evaluate() は各行に対して呼び出されるエントリーポイントです。
          // パラメーターと戻り値の型は MaxCompute SQL 型 (String -> STRING) にマッピングされます。
          public String evaluate(String s) {
              if (s == null) {                 // 実行時エラーを回避するために、常に NULL 入力を処理します
                  return null;
              }
              return s.toLowerCase();
          }
      }

      注：<packagename> を実際のパッケージ名 (例：com.example) に置き換えてください。

2. UDF をローカルでデバッグします。

   デプロイ前に MaxCompute テーブルに対して UDF をローカルで実行し、ロジックを検証します。

   1. java ディレクトリで、Java ファイルを右クリックし、[Run] を選択します。

   2. [Run/Debug Configurations] ダイアログボックスで、次のフィールドを設定します。

      

      • MaxCompute project：UDF が実行される MaxCompute プロジェクト。ドロップダウンリストから local を選択すると、クラスターに送信せずにローカルで実行されます。

      • MaxCompute table：ローカル実行の入力データを提供する MaxCompute テーブルの名前。

      • Table columns：UDF が操作する MaxCompute テーブルの列。

   3. [OK] をクリックします。UDF がローカルで実行され、戻り結果が出力パネルに表示されます。

      ヒント：ローカルでの実行が成功すると、evaluate() メソッドが入力型と NULL 値を正しく処理していることが確認できます。デプロイに進む前に、エラーを修正してください。

3. UDF を MaxCompute にデプロイします。

   ローカルテストに合格したら、UDF をパッケージ化して登録し、SQL で使用できるようにします。

   1. UDF の Java ファイルを右クリックし、[Deploy to Server...] を選択します。

   2. [Package a jar, submit resource and register function] ダイアログボックスで、次のフィールドを設定します。

      

      • MaxCompute project：デプロイ先のプロジェクト。デフォルト値は、UDF の作成時に接続したプロジェクトを反映しています。別のプロジェクトを対象としない限り、デフォルト値を保持してください。

      • Resource file：JAR リソースファイルのパス。デフォルト値を保持してください。

      • Resource name：MaxCompute に登録されるリソースの名前。デフォルト値を保持してください。

      • Function name：SQL ステートメントで UDF を呼び出すために使用される名前。Lower_test と入力します。

      警告：[Function name] の値は、SQL クエリで使用する名前です。MaxCompute の組み込み関数と競合する名前は避けてください。競合が存在する場合、カスタム UDF が組み込み関数をシャドウイングしたり、オーバーライドに失敗したりする可能性があります。

   3. [OK] をクリックします。MaxCompute Studio はコードを JAR にパッケージ化し、リソースとしてアップロードし、選択したプロジェクトに Lower_test を関数として登録します。

4. SQL で UDF を呼び出します。

   1. 左側のナビゲーションウィンドウで、[Project Explorer] タブに移動します。

   2. ご利用の MaxCompute プロジェクトを右クリックし、[Open in Console] を選択します。

   3. コンソールで、次の SQL ステートメントを入力し、Enter キーを押します。

      select Lower_test('ALIYUN');

      

   4. 出力を確認します。次の結果が返され、Lower_test Java UDF が正しく機能していることを示します。

      期待される出力：
      +------------+
      | _c0        |
      +------------+
      | aliyun     |
      +------------+