com.aliyun.odps.udf

类 UDTF

java.lang.Object

com.aliyun.odps.udf.UDTF

所有已实现的接口:

ContextFunction

直接已知子类:

StandaloneUDTF

public abstract class UDTF
extends Object
implements ContextFunction

UDTF 是 User Defined Table-generating Function 缩写，用来解决一次函数调用输出多行数据的场景，也是唯一能返回多个字段的自定义函数。

用户代码需继承此类，编写 process(Object[]) 方法来完成具体的数据操作，实现一个 UDTF 的功能。
行数据输出的过程通过调用 forward(Object...) 实现。

实例代码：

构造器概要

构造器

构造器和说明
UDTF()

方法概要

方法

限定符和类型	方法和说明
void	close() 在UDTF运行期，process(Object[])把全部记录处理完以之后， 即当前实例没有其它需要处理的记录了，close()}此时会被调用一次。
UDTFCollector	getCollector() 获取UDTF的默认UDTFCollector对象。
OdpsType[]	initialize(OdpsType[] inputTypes) 已过时。
abstract void	process(Object[] args) 用户代码必须实现process(Object[])方法。
OdpsType[]	resolve(OdpsType[] inputTypes) 用于输入、输出类型 OdpsType 之间的转换，默认调用 initialize(OdpsType[]) 不存在转换问题通常不需要关心。
void	setCollector(UDTFCollector collector) 设置 UDTFCollector，以便该 UDTFCollector 对象与 UDTF 实例相关联。
void	setup(ExecutionContext ctx) 在UDTF运行期，在每个Worker内setup(ExecutionContext)会被先调用一次。

从类继承的方法 java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

UDTF

public UDTF()

方法详细资料

initialize

@Deprecated
public OdpsType[] initialize(OdpsType[] inputTypes)
                      throws Exception

已过时。

不推荐使用 用于输入、输出类型 OdpsType 之间的转换

参数:

inputTypes - 输入的类型

返回:

转换后的输出类型

抛出:

Exception - 任何异常均会抛出 建议使用 Resolve 替代

resolve

public OdpsType[] resolve(OdpsType[] inputTypes)
                   throws UDFException

用于输入、输出类型 OdpsType 之间的转换，默认调用 initialize(OdpsType[]) 不存在转换问题通常不需要关心。

参数:

inputTypes - 输入的类型

返回:

转换后的输出类型

抛出:

UDFException - 通用UDF异常

setup

public void setup(ExecutionContext ctx)
           throws UDFException

在UDTF运行期，在每个Worker内setup(ExecutionContext)会被先调用一次。

默认实现为空实现，用户代码可以通过覆盖此方法，在setup(ExecutionContext)中完成初始化的工作。

指定者:

setup 在接口中 ContextFunction

参数:

ctx - UDF所在运行时上下文信息，包括UDF所在的StageID、WorkerID等信息

抛出:

UDFException - 通用UDF异常

process

public abstract void process(Object[] args)
                      throws UDFException

用户代码必须实现process(Object[])方法。

对SQL中每一条记录，process(Object[])方法都会被调用一次。

参数:

args - 参数数组，对应SQL调用时的参数。

抛出:

UDFException - 通用UDF异常

close

public void close()
           throws UDFException

在UDTF运行期，process(Object[])把全部记录处理完以之后， 即当前实例没有其它需要处理的记录了，close()}此时会被调用一次。

默认实现为空实现，用户代码可以覆盖此方法。

指定者:

close 在接口中 ContextFunction

抛出:

UDFException - 通用UDF异常

setCollector

public void setCollector(UDTFCollector collector)

设置 UDTFCollector，以便该 UDTFCollector 对象与 UDTF 实例相关联。
由于 UDTF 可能会在 UDTFCollector 构造之前被初始化，所以不能在 UDTF 的构造函数中指定 UDTFCollector 。

设置一个实现UDTFCollector接口的对象。注意：如果在运行期户代码通过调用此方法覆盖默认的UDTFCollector对象，将会造成UDTF无法正常输出。

参数:

collector - 一个实现了UDTFCollector接口的对象。

另请参阅:

UDTFCollector

getCollector

public UDTFCollector getCollector()

获取UDTF的默认UDTFCollector对象。

UDTF在运行时，会被初始化一个实现了UDTFCollector接口的对象，用户代码通过 forward(Object...) 间接调用 UDTFCollector.collect(Object[])，将结果输出。

返回:

一个初始化好的，实现了UDTFCollector接口的对象。

另请参阅:

UDTFCollector