com.aliyun.odps.udf

类 StandaloneUDTF

java.lang.Object

com.aliyun.odps.udf.UDTF

com.aliyun.odps.udf.StandaloneUDTF

所有已实现的接口:

ContextFunction

public abstract class StandaloneUDTF
extends UDTF

具有拉数据功能的UDTF，可以主动调用getNextRow()获取一条记录。 仅在LOT中才能使用，并且有如下限制： 1. 在一个stage中只能有一个StandaloneUDTF 2. StandaloneUDTF在LOT的结构中不能有siblings

构造器概要

构造器

构造器和说明
StandaloneUDTF()

方法概要

方法

限定符和类型	方法和说明
Object[]	getNextRow() 获取下一条记录
UDTFPuller	getPuller()
void	init(UDTFPuller puller) 该方法由框架调用来初始化 StandaloneUDTF
void	run() run方法默认实现，每拉一条记录，调用一次process方法。

从类继承的方法 com.aliyun.odps.udf.UDTF

close, getCollector, initialize, process, resolve, setCollector, setup

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

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

构造器详细资料

StandaloneUDTF

public StandaloneUDTF()

方法详细资料

init

public final void init(UDTFPuller puller)

该方法由框架调用来初始化 StandaloneUDTF

run

public void run()
         throws UDFException

run方法默认实现，每拉一条记录，调用一次process方法。

抛出:

UDFException

getNextRow

public final Object[] getNextRow()

获取下一条记录

返回:

getPuller

public final UDTFPuller getPuller()