A C E G I M N O P R S T U V

A

Aggregator - com.aliyun.odps.udf中的类

继承 Aggregator 实现 UDAF。

Aggregator() - 类 的构造器com.aliyun.odps.udf.Aggregator

AnnotationParser - com.aliyun.odps.udf.impl中的类

UDF SDK中用于内部实现的功能，这部分不属于API的一部分，接口随时可能改变，不推荐使用。

AnnotationParser() - 类 的构造器com.aliyun.odps.udf.impl.AnnotationParser

AnnotationParser.ParseError - com.aliyun.odps.udf.impl中的异常错误

AnnotationParser.ParseError(Throwable) - 异常错误 的构造器com.aliyun.odps.udf.impl.AnnotationParser.ParseError

AnnotationParser.ParseError(String) - 异常错误 的构造器com.aliyun.odps.udf.impl.AnnotationParser.ParseError

AnnotationParser.ParseResult - com.aliyun.odps.udf.impl中的类

AnnotationParser.ParseResult() - 类 的构造器com.aliyun.odps.udf.impl.AnnotationParser.ParseResult

AnnotationParser.Prototype - com.aliyun.odps.udf.impl中的类

AnnotationParser.Prototype() - 类 的构造器com.aliyun.odps.udf.impl.AnnotationParser.Prototype

C

claimAlive() - 类 中的方法com.aliyun.odps.udf.ExecutionContext

在UDF运行期调用此方法防止worker因超时被强制终止。

close() - 类 中的方法com.aliyun.odps.udf.Aggregator

扫尾工作

close() - 接口 中的方法com.aliyun.odps.udf.ContextFunction

close() - 类 中的方法com.aliyun.odps.udf.UDF

close() - 类 中的方法com.aliyun.odps.udf.UDTF

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

collect(Object[]) - 接口 中的方法com.aliyun.odps.udf.UDTFCollector

其它类（UDTF）会调用此方法，以收集每一行数据

com.aliyun.odps.udf - 程序包 com.aliyun.odps.udf

UDF API 主要包括 UDF（User Defined Function，用户自定义函数） 和 UDTF （User Defined Table-generating Function，用户自定义生成表函数）

com.aliyun.odps.udf.annotation - 程序包 com.aliyun.odps.udf.annotation

UDF annotation，用于在Java代码中静态标记UDF的输入、输出类型。

com.aliyun.odps.udf.impl - 程序包 com.aliyun.odps.udf.impl

UDF SDK中用于内部实现的功能，这部分不属于API的一部分，接口随时可能改变，不推荐使用。

com.aliyun.odps.udf.utils - 程序包 com.aliyun.odps.udf.utils

ContextFunction - com.aliyun.odps.udf中的接口

拥有 ExecutionContext的一类自定义函数。

CounterUtils - com.aliyun.odps.udf.utils中的类

与 Counter 相关的静态工具类，包含一些工具方法

CounterUtils() - 类 的构造器com.aliyun.odps.udf.utils.CounterUtils

createFromJsonString(String) - 类 中的静态方法com.aliyun.odps.udf.utils.CounterUtils

通过JSON字符串创建Counters对象 字符串异常时会抛出 RuntimeException

E

ExecutionContext - com.aliyun.odps.udf中的类

运行时的执行上下文信息。

ExecutionContext() - 类 的构造器com.aliyun.odps.udf.ExecutionContext

G

getArguments() - 类 中的方法com.aliyun.odps.udf.impl.AnnotationParser.Prototype

getArgumentsString() - 类 中的方法com.aliyun.odps.udf.impl.AnnotationParser.Prototype

getCollector() - 类 中的方法com.aliyun.odps.udf.UDTF

获取UDTF的默认UDTFCollector对象。

getCounter(Enum<?>) - 类 中的方法com.aliyun.odps.udf.ExecutionContext

通过Enum获取Counter 等价于调用 getCounter(name.getDeclaringClass().getName(), name.toString())

getCounter(String, String) - 类 中的方法com.aliyun.odps.udf.ExecutionContext

通过Group名和Counter名获取Counter Counter信息最后会汇总在SQL Task的Summary中。

getInputVolumeFileSystem() - 类 中的方法com.aliyun.odps.udf.ExecutionContext

getInputVolumeFileSystem(String) - 类 中的方法com.aliyun.odps.udf.ExecutionContext

getInputVolumeInfo() - 类 中的方法com.aliyun.odps.udf.ExecutionContext

getInputVolumeInfo(String) - 类 中的方法com.aliyun.odps.udf.ExecutionContext

getNextRow() - 类 中的方法com.aliyun.odps.udf.StandaloneUDTF

获取下一条记录

getNextRow() - 接口 中的方法com.aliyun.odps.udf.UDTFPuller

从数据源中获取一条记录。

getOutputVolumeFileSystem() - 类 中的方法com.aliyun.odps.udf.ExecutionContext

getOutputVolumeFileSystem(String) - 类 中的方法com.aliyun.odps.udf.ExecutionContext

getOutputVolumeInfo() - 类 中的方法com.aliyun.odps.udf.ExecutionContext

getOutputVolumeInfo(String) - 类 中的方法com.aliyun.odps.udf.ExecutionContext

getProtoTypes() - 类 中的方法com.aliyun.odps.udf.impl.AnnotationParser.ParseResult

getPuller() - 类 中的方法com.aliyun.odps.udf.StandaloneUDTF

getReturns() - 类 中的方法com.aliyun.odps.udf.impl.AnnotationParser.Prototype

getReturnsString() - 类 中的方法com.aliyun.odps.udf.impl.AnnotationParser.Prototype

getStageID() - 类 中的方法com.aliyun.odps.udf.ExecutionContext

获取运行时StageID

getTableInfo() - 类 中的方法com.aliyun.odps.udf.ExecutionContext

获取运行时处理的数据块所属的表或分区信息。

getWorkerID() - 类 中的方法com.aliyun.odps.udf.ExecutionContext

获取运行时WorkerID

I

init(UDTFPuller) - 类 中的方法com.aliyun.odps.udf.StandaloneUDTF

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

initialize(OdpsType[]) - 类 中的方法com.aliyun.odps.udf.UDTF

已过时。

InvalidInvocationException - com.aliyun.odps.udf中的异常错误

InvalidInvocationException(Throwable) - 异常错误 的构造器com.aliyun.odps.udf.InvalidInvocationException

InvalidInvocationException(String) - 异常错误 的构造器com.aliyun.odps.udf.InvalidInvocationException

isVariadic() - 类 中的方法com.aliyun.odps.udf.impl.AnnotationParser.ParseResult

isWriable() - 类 中的方法com.aliyun.odps.udf.impl.AnnotationParser.ParseResult

iterate(Writable, Writable[]) - 类 中的方法com.aliyun.odps.udf.Aggregator

对输入进行计算，生成中间结果

M

merge(Writable, Writable) - 类 中的方法com.aliyun.odps.udf.Aggregator

聚合中间结果，将 partial merge 到 buffer

N

newBuffer() - 类 中的方法com.aliyun.odps.udf.Aggregator

创建聚合Buffer

O

OdpsType - com.aliyun.odps.udf中的枚举

映射到ODPS数据类型，包括 STRING：字符串 BIGINT：长整数型 DOUBLE：双精度符点数类型 BOOLEAN：双精度符点数类型 IGNORE：忽略类型映射 不推荐直接使用。

P

parse(Class<?>) - 类 中的静态方法com.aliyun.odps.udf.impl.AnnotationParser

PreferWritable - com.aliyun.odps.udf.annotation中的注释类型

process(Object[]) - 类 中的方法com.aliyun.odps.udf.UDTF

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

R

readResourceFile(String) - 类 中的方法com.aliyun.odps.udf.ExecutionContext

读取文件类型资源，一次全部读取到内存，返回 byte[].

readResourceFileAsStream(String) - 类 中的方法com.aliyun.odps.udf.ExecutionContext

读取文件类型资源，返回一个带缓存的输入流。

readResourceTable(String) - 类 中的方法com.aliyun.odps.udf.ExecutionContext

读取表类型资源，返回Iterable，Object为对应表每一列的Java原生类型.

Resolve - com.aliyun.odps.udf.annotation中的注释类型

用于指定UDTF的输入输出类型。

resolve(OdpsType[]) - 类 中的方法com.aliyun.odps.udf.UDTF

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

run() - 类 中的方法com.aliyun.odps.udf.StandaloneUDTF

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

S

setArguments(OdpsType[]) - 类 中的方法com.aliyun.odps.udf.impl.AnnotationParser.Prototype

setCollector(UDTFCollector) - 类 中的方法com.aliyun.odps.udf.UDTF

设置 UDTFCollector，以便该 UDTFCollector 对象与 UDTF 实例相关联。

setReturns(OdpsType[]) - 类 中的方法com.aliyun.odps.udf.impl.AnnotationParser.Prototype

setTp(List<AnnotationParser.Prototype>) - 类 中的方法com.aliyun.odps.udf.impl.AnnotationParser.ParseResult

setup(ExecutionContext) - 类 中的方法com.aliyun.odps.udf.Aggregator

初始化工作。

setup(ExecutionContext) - 接口 中的方法com.aliyun.odps.udf.ContextFunction

setup(ExecutionContext) - 类 中的方法com.aliyun.odps.udf.UDF

setup(ExecutionContext) - 类 中的方法com.aliyun.odps.udf.UDTF

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

setVariadic(boolean) - 类 中的方法com.aliyun.odps.udf.impl.AnnotationParser.ParseResult

setWritable(boolean) - 类 中的方法com.aliyun.odps.udf.impl.AnnotationParser.ParseResult

StandaloneUDTF - com.aliyun.odps.udf中的类

具有拉数据功能的UDTF，可以主动调用getNextRow()获取一条记录。

StandaloneUDTF() - 类 的构造器com.aliyun.odps.udf.StandaloneUDTF

T

terminate(Writable) - 类 中的方法com.aliyun.odps.udf.Aggregator

生成最终结果

toJsonString(Counters) - 类 中的静态方法com.aliyun.odps.udf.utils.CounterUtils

将 Counters 对象转化成一个JSON字符串

U

UDF - com.aliyun.odps.udf中的类

UDF 基类 UDF (User Defined Scalar Function) 自定义函数，其输入输出是一对一的关系，即读入一行数据，写出一条输出值。

UDF() - 类 的构造器com.aliyun.odps.udf.UDF

UDFException - com.aliyun.odps.udf中的异常错误

通用的UDF异常类，用于封装UDF运行期间的各种异常。

UDFException(String) - 异常错误 的构造器com.aliyun.odps.udf.UDFException

UDFException(Throwable) - 异常错误 的构造器com.aliyun.odps.udf.UDFException

UDTF - com.aliyun.odps.udf中的类

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

UDTF() - 类 的构造器com.aliyun.odps.udf.UDTF

UDTFCollector - com.aliyun.odps.udf中的接口

从UDTF数据源收集数据 通常 UDTF.forward(Object...)会把每一行数据传入UDTFCollector

UDTFPuller - com.aliyun.odps.udf中的接口

V

valueOf(String) - 枚举 中的静态方法com.aliyun.odps.udf.OdpsType

返回带有指定名称的该类型的枚举常量。

values() - 枚举 中的静态方法com.aliyun.odps.udf.OdpsType

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

A C E G I M N O P R S T U V