| Package | Description |
|---|---|
| com.aliyun.odps.mapred.unittest |
| Modifier and Type | Method and Description |
|---|---|
List<KeyValue<Record,Record>> |
ReduceUTContext.getInputKeyVals() |
List<KeyValue<Record,Record>> |
TaskOutput.getOutputKeyValues()
|
List<KeyValue<Record,Record>> |
TaskOutput.getOutputKeyValues(int reduceId)
返回
Mapper 输出到给定 reduceId 的键值对列表. |
| Modifier and Type | Method and Description |
|---|---|
void |
ReduceUTContext.addInputKeyValues(List<KeyValue<Record,Record>> kvs)
给定键值对列表,增加
Reducer 输入的键值对. |
Copyright © 2020 Alibaba Cloud Computing. All rights reserved.