将这个jar包命名为”my_lower.jar”。

备注：SDK的使用信息请参考UDF SDK 。

• 添加资源：在运行UDF之前，必须指定引用的UDF代码。用户代码通过资源的形式添加到ODPS中。Java UDF必须被打成jar包，以jar资源添加到ODPS中，UDF框架会自动加载jar包，运行用户自定义的UDF。 ODPS MapReduce也用到了资源这一特有概念，MapReduce文档中对资源的使用也有阐述。

执行命令：

add jar my_lower.jar;
    -- 如果存在同名的资源请将这个jar包重命名，
    -- 并注意修改下面示例命令中相关jar包的名字；
    -- 又或者直接使用-f选项覆盖原有的jar资源

• 注册UDF函数：用户的jar包被上传后，使得 MaxCompute 有条件自动获取用户代码并运行。但此时仍然无法使用这个UDF，因为 MaxCompute 中并没有关于这个UDF的任何信息。因此需要用户在 MaxCompute 中注册一个唯一的函数名，并指定这个函数名与哪个jar资源的哪个函数对应。关于如何注册 UDF，请参考 注册函数 。运行命令：

 CREATE FUNCTION test_lower AS org.alidata.odps.udf.examples.Lower USING my_lower.jar;

在sql中使用此函数：

select test_lower('A') from my_test_table;

UDAF示例

UDAF的注册方式与UDF基本相同，使用方式与内建函数中得 聚合函数 相同。下面是一个计算平均值的UDAF的代码示例:

package org.alidata.odps.udf.examples;
import com.aliyun.odps.io.LongWritable;
import com.aliyun.odps.io.Text;
import com.aliyun.odps.io.Writable;
import com.aliyun.odps.udf.Aggregator;
import com.aliyun.odps.udf.UDFException;
/**
 * project: example_project
 * table: wc_in2
 * partitions: p2=1,p1=2
 * columns: colc,colb,cola
 */
public class UDAFExample extends Aggregator {
  @Override
  public void iterate(Writable arg0, Writable[] arg1) throws UDFException {
    LongWritable result = (LongWritable) arg0;
    for (Writable item : arg1) {
      Text txt = (Text) item;
      result.set(result.get() + txt.getLength());
    }
  }
  @Override
  public void merge(Writable arg0, Writable arg1) throws UDFException {
    LongWritable result = (LongWritable) arg0;
    LongWritable partial = (LongWritable) arg1;
    result.set(result.get() + partial.get());
  }
  @Override
  public Writable newBuffer() {
    return new LongWritable(0L);
  }
  @Override
  public Writable terminate(Writable arg0) throws UDFException {
    return arg0;
  }
}

package org.alidata.odps.udtf.examples;
import com.aliyun.odps.udf.UDTF;
import com.aliyun.odps.udf.UDTFCollector;
import com.aliyun.odps.udf.annotation.Resolve;
import com.aliyun.odps.udf.UDFException;
// TODO define input and output types, e.g., "string,string->string,bigint".
@Resolve({"string,bigint->string,bigint"})
public class MyUDTF extends UDTF {
  @Override
  public void process(Object[] args) throws UDFException {
    String a = (String) args[0];
    Long b = (Long) args[1];
    for (String t: a.split("\s+")) {
      forward(t, b);
    }
  }
}