udf函数是什么?
maxcompute自带了一些函数比如:max/min/sum 等,但是由于自带的函数数量有限且实现的功能有较大的局限性,通常不能满足业务的需要,这时用户可以自己定义udf来方便扩展。udf 函数可以直接应用于select 语句,对查询结构做格式化处理之后,然后再输出内容。
注意点:
1.Python UDF必须通过annotate指定函数签名。
2.必须实现 evaluate 方法
操作步骤:
step1:
创建python类型ud资源:
案例如下:(实现两个bigint类型字段值相加)
from odps.udf import annotate
@annotate ( "bigint,bigint->bigint" )
class MyPlus ( object ):
def evaluate ( self , arg0 , arg1 ):
if None in ( arg0 , arg1 ):
return None
return arg0 + arg1
step2:
根据资源来配置创建函数:
<br/>
注意点1:类名为资源文件名.class类名
注意点2:资源列表中填写 所有 用到的文件(例如udf中用到的其他文本类型文件等),用英文逗号分隔
step3:
调用函数实现业务需求:
注意点1:调用语句中使用的是函数名
DataWorks百问百答历史记录 请点击这里查看>>
更多DataWorks技术和产品信息,欢迎加入【DataWorks钉钉交流群】