com.aliyun.odps.mapred.unittest

Class MapUTContext

java.lang.Object

com.aliyun.odps.mapred.unittest.UTContext

com.aliyun.odps.mapred.unittest.MapUTContext

public class MapUTContext
extends UTContext

Mapper 单元测试的上下文.

编写 Mapper 单元测试需要用到此上下文。

See Also:

MRUnitTest#runMapper(com.aliyun.odps.mapreduce.JobConf, MapUTContext)

Constructor Summary

Constructors

Constructor and Description
MapUTContext()

Method Summary

Modifier and Type	Method and Description
void	addInputRecord(Record record) 增加 Map 输入记录.
void	addInputRecords(Collection<Record> records) 增加 Map 输入记录.
void	addInputRecordsFromDir(File dir) 给定一个本地表目录，增加 Map 输入记录.
void	clearInputRecords() 清空 Map 输入记录.
Record	createInputRecord() 创建 Map 输入的记录对象.
List<Record>	getInputRecords() 获取 Map 输入的记录列表.
String	getInputSchema()
void	setInputSchema(String inputSchema) 设置 Map 输入的 schema.

Methods inherited from class com.aliyun.odps.mapred.unittest.UTContext

getTaskId, isCleanUtDir, setArchiveResource, setCleanUtDir, setFileResource, setFileResource, setFileResource, setOutputSchema, setOutputSchema, setTableResource, setTableResource, setTaskId

Methods inherited from class java.lang.Object

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

Constructor Detail

MapUTContext

public MapUTContext()

Method Detail

addInputRecord

public void addInputRecord(Record record)

增加 Map 输入记录.

Parameters:

record -

addInputRecords

public void addInputRecords(Collection<Record> records)

增加 Map 输入记录.

Parameters:

records -

addInputRecordsFromDir

public void addInputRecordsFromDir(File dir)
                            throws IOException

给定一个本地表目录，增加 Map 输入记录.

Parameters:

dir -

Throws:

IOException

getInputRecords

public List<Record> getInputRecords()

获取 Map 输入的记录列表.

Returns:

clearInputRecords

public void clearInputRecords()

清空 Map 输入记录.

setInputSchema

public void setInputSchema(String inputSchema)
                    throws IOException

设置 Map 输入的 schema.

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

Parameters:

inputSchema - Map 输入的 schema

Throws:

IOException

getInputSchema

public String getInputSchema()

createInputRecord

public Record createInputRecord()
                         throws IOException

创建 Map 输入的记录对象.

记录的 schema 通过 setInputSchema(String) 设置。

Returns:

Map 输入的记录对象

Throws:

IOException