com.aliyun.odps.mapred.unittest

Class ReduceUTContext

java.lang.Object

com.aliyun.odps.mapred.unittest.UTContext

com.aliyun.odps.mapred.unittest.ReduceUTContext

Type Parameters:

K - Reducer 输入的 Key 类型

V - Reducer 输入的 Value 类型

public class ReduceUTContext
extends UTContext

Reducer 单元测试的上下文.

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

See Also:

MRUnitTest#runReducer(com.aliyun.odps.mapreduce.JobConf, ReduceUTContext)

Constructor Summary

Constructors

Constructor and Description
ReduceUTContext()

Method Summary

Modifier and Type	Method and Description
void	addInputKeyValue(Record k, Record v) 增加 Reducer 输入的键值对.
void	addInputKeyValues(List<KeyValue<Record,Record>> kvs) 给定键值对列表，增加 Reducer 输入的键值对.
void	addInputKeyValues(TaskOutput mapOutput) 给定 MapOutput，增加 Reducer 输入的键值对.
void	addInputKeyValues(TaskOutput mapOutput, int reduceId) 给定 MapOutput 和 reduceId，增加 Reducer 输入的键值对.
Record	createInputKeyRecord(com.aliyun.odps.conf.Configuration conf) 创建 Reduce 输入的key记录对象.
Record	createInputValueRecord(com.aliyun.odps.conf.Configuration conf) 创建 Reduce 输入的value记录对象.
List<KeyValue<Record,Record>>	getInputKeyVals()
int	getReducerIndex()
void	setReducerIndex(int reducerIndex)

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

ReduceUTContext

public ReduceUTContext()

Method Detail

createInputKeyRecord

public Record createInputKeyRecord(com.aliyun.odps.conf.Configuration conf)
                            throws IOException

创建 Reduce 输入的key记录对象.

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

Returns:

Map 输入的记录对象

Throws:

IOException

createInputValueRecord

public Record createInputValueRecord(com.aliyun.odps.conf.Configuration conf)
                              throws IOException

创建 Reduce 输入的value记录对象.

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

Returns:

Map 输入的记录对象

Throws:

IOException

addInputKeyValue

public void addInputKeyValue(Record k,
                             Record v)

增加 Reducer 输入的键值对.

Parameters:

k - Reducer 输入的 Key 对象

v - Reducer 输入的 Value 对象

addInputKeyValues

public void addInputKeyValues(List<KeyValue<Record,Record>> kvs)

给定键值对列表，增加 Reducer 输入的键值对.

Parameters:

kvs - Reducer 输入的键值对列表

addInputKeyValues

public void addInputKeyValues(TaskOutput mapOutput)

给定 MapOutput，增加 Reducer 输入的键值对.

将 Mapper 的结果键值对作为 Reducer 的输入，等价于：

 addInputKeyValues(mapOutput.getOutputKeyValues());
 

Parameters:

mapOutput -

addInputKeyValues

public void addInputKeyValues(TaskOutput mapOutput,
                              int reduceId)

给定 MapOutput 和 reduceId，增加 Reducer 输入的键值对.

将 Mapper 写给 reduceId 的结果键值对作为 Reducer 的输入，等价于：

 addInputKeyValues(mapOutput.getOutputKeyValues(reduceId));
 

Parameters:

mapOutput -

reduceId -

getInputKeyVals

public List<KeyValue<Record,Record>> getInputKeyVals()

getReducerIndex

public int getReducerIndex()

setReducerIndex

public void setReducerIndex(int reducerIndex)