com.aliyun.odps.mapred.unittest

Class UTContext

java.lang.Object

com.aliyun.odps.mapred.unittest.UTContext

Direct Known Subclasses:

MapUTContext, ReduceUTContext

public abstract class UTContext
extends Object

MapReduce Unit Test 上下文基类.

MapUTContext 和 ReduceUTContext 的基类，定义一些共同的方法。

Constructor Summary

Constructors

Constructor and Description
UTContext()

Method Summary

Modifier and Type	Method and Description
int	getTaskId() 返回设置的TaskId，不设默认为 0.
boolean	isCleanUtDir()
void	setArchiveResource(String resourceName, File path) 定义压缩档案资源.
void	setCleanUtDir(boolean isClean)
void	setFileResource(String resourceName, byte[] content) 给定文件内容，设置文件类型资源.
void	setFileResource(String resourceName, File file) 给定本地资源文件，设置文件类型资源.
void	setFileResource(String resourceName, String content) 给定文件内容，设置文件类型资源.
void	setOutputSchema(String schema, com.aliyun.odps.conf.Configuration conf) 设置默认输出的 schema.
void	setOutputSchema(String label, String schema, com.aliyun.odps.conf.Configuration conf) 给定输出的标签，设置 schema.
void	setTableResource(String resourceName, File dir) 给定本地表目录，设置表类型资源.
void	setTableResource(String resourceName, TableInfo info, String schema, List<Record> records) 给定记录列表和表信息，设置表类型资源.
void	setTaskId(int taskId) 设置 TaskId，不设默认为 0.

Methods inherited from class java.lang.Object

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

Constructor Detail

UTContext

public UTContext()

Method Detail

getTaskId

public int getTaskId()

返回设置的TaskId，不设默认为 0.

Returns:

TaskId

setTaskId

public void setTaskId(int taskId)

设置 TaskId，不设默认为 0.

运行时可以从 TaskAttemptID#getTaskId() 取得。

Parameters:

taskId -

setFileResource

public void setFileResource(String resourceName,
                            File file)
                     throws IOException

给定本地资源文件，设置文件类型资源.

如果在 Mapper 或 Reducer 里用到文件资源，可以通过本方法预先定义文件资源。

Parameters:

resourceName - 资源名称

file - 本地资源文件

Throws:

IOException

setFileResource

public void setFileResource(String resourceName,
                            String content)
                     throws IOException

给定文件内容，设置文件类型资源.

如果在 Mapper 或 Reducer 里用到文件资源，可以通过本方法预先定义文件资源。

Parameters:

resourceName - 资源名称

content - 文件内容

Throws:

IOException

setFileResource

public void setFileResource(String resourceName,
                            byte[] content)
                     throws IOException

给定文件内容，设置文件类型资源.

如果在 Mapper 或 Reducer 里用到文件资源，可以通过本方法预先定义文件资源。

Parameters:

resourceName - 资源名称

content - 文件内容

Throws:

IOException

setArchiveResource

public void setArchiveResource(String resourceName,
                               File path)
                        throws IOException

定义压缩档案资源.

如果在 Mapper 或 Reducer 里用到压缩档案资源，可以通过本方法预先定义。

Parameters:

resourceName - 资源名称

path - 本地压缩文件或本地压缩文件解压的文件目录

Throws:

IOException

setTableResource

public void setTableResource(String resourceName,
                             TableInfo info,
                             String schema,
                             List<Record> records)
                      throws IOException

给定记录列表和表信息，设置表类型资源.

如果在 Mapper 或 Reducer 里用到表类型资源，可以通过本方法预先定义。

给定 schema 的格式为：[.,]:(,:)*
例如：

• proj.tablename,a:string,b:bigint,c:double
• a:string,b:bigint,c:double

Parameters:

resourceName - 资源名称

info - 表信息

schema - 表 schema

records - 表的记录集合

Throws:

IOException

setTableResource

public void setTableResource(String resourceName,
                             File dir)
                      throws IOException

给定本地表目录，设置表类型资源.

一个本地表目录至少包含一个名为"__schema__"的 schema 文件，其他文件都为数据文件，格式为标准的csv格式。

Parameters:

resourceName - 资源名称

dir - 本地表目录

Throws:

IOException

setOutputSchema

public void setOutputSchema(String schema,
                            com.aliyun.odps.conf.Configuration conf)
                     throws IOException

设置默认输出的 schema.

schema 的格式为：:(,:)*
例如：a:string,b:bigint,c:double

如果通过 TableOutputFormat#addOutput(TableInfo, com.aliyun.odps.conf.Configuration) 设置了默认输出，则需要使用本方法设置默认输出的 schema。

Parameters:

schema - 默认输出的 schema

Throws:

IOException

setOutputSchema

public void setOutputSchema(String label,
                            String schema,
                            com.aliyun.odps.conf.Configuration conf)
                     throws IOException

给定输出的标签，设置 schema.

schema 的格式为：:(,:)*
例如：a:string,b:bigint,c:double

如果通过 TableOutputFormat#addOutput(TableInfo, String, com.aliyun.odps.conf.Configuration) 设置了给定标签的输出，则需要使用本方法设置其 schema。

Parameters:

label - 输出的标签

schema - 输出的 schema

Throws:

IOException

isCleanUtDir

public boolean isCleanUtDir()

setCleanUtDir

public void setCleanUtDir(boolean isClean)