A C D E G H I J K L M N O P R S T U V W

A

add(Record, Record) - Method in class com.aliyun.odps.mapred.local.MapOutputBuffer

add(Record, Record, int) - Method in class com.aliyun.odps.mapred.local.MapOutputBuffer

add(Record, String) - Method in class com.aliyun.odps.mapred.local.MapOutputBuffer

add(Record, Record) - Method in class com.aliyun.odps.mapred.unittest.TaskOutput

add(Record, Record, int) - Method in class com.aliyun.odps.mapred.unittest.TaskOutput

add(Record, String) - Method in class com.aliyun.odps.mapred.unittest.TaskOutput

addInputKeyValue(Record, Record) - Method in class com.aliyun.odps.mapred.unittest.ReduceUTContext

增加 Reducer 输入的键值对.

addInputKeyValues(List<KeyValue<Record, Record>>) - Method in class com.aliyun.odps.mapred.unittest.ReduceUTContext

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

addInputKeyValues(TaskOutput) - Method in class com.aliyun.odps.mapred.unittest.ReduceUTContext

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

addInputKeyValues(TaskOutput, int) - Method in class com.aliyun.odps.mapred.unittest.ReduceUTContext

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

addInputRecord(Record) - Method in class com.aliyun.odps.mapred.unittest.MapUTContext

增加 Map 输入记录.

addInputRecords(Collection<Record>) - Method in class com.aliyun.odps.mapred.unittest.MapUTContext

增加 Map 输入记录.

addInputRecordsFromDir(File) - Method in class com.aliyun.odps.mapred.unittest.MapUTContext

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

C

clearInputRecords() - Method in class com.aliyun.odps.mapred.unittest.MapUTContext

清空 Map 输入记录.

close() - Method in class com.aliyun.odps.mapred.local.CSVRecordReader

close() - Method in class com.aliyun.odps.mapred.local.CSVRecordWriter

closeWriters() - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

com.aliyun.odps.mapred - package com.aliyun.odps.mapred

com.aliyun.odps.mapred.local - package com.aliyun.odps.mapred.local

com.aliyun.odps.mapred.local.utils - package com.aliyun.odps.mapred.local.utils

com.aliyun.odps.mapred.unittest - package com.aliyun.odps.mapred.unittest

compare(Object[], Object[]) - Method in class com.aliyun.odps.mapred.local.utils.LocalColumnBasedRecordComparator

compare(Record, Record) - Method in class com.aliyun.odps.mapred.unittest.LocalRecordComparator

比较两个 Record.

containsKey(String) - Method in class com.aliyun.odps.mapred.unittest.RuntimeContext

create(String, JobConf) - Static method in class com.aliyun.odps.mapred.unittest.RuntimeContext

createCombiner() - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

createInputKeyRecord(Configuration) - Method in class com.aliyun.odps.mapred.unittest.ReduceUTContext

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

createInputRecord() - Method in class com.aliyun.odps.mapred.unittest.MapUTContext

创建 Map 输入的记录对象.

createInputValueRecord(Configuration) - Method in class com.aliyun.odps.mapred.unittest.ReduceUTContext

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

createMapOutputKeyRecord() - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

createMapOutputValueRecord() - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

createMapper() - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

createOutputKeyRecord() - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

createOutputRecord() - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

createOutputRecord(String) - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

createOutputValueRecord() - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

createRecord(String) - Static method in class com.aliyun.odps.mapred.unittest.MRUnitTest

给定 schema 创建记录对象（Record）.

createReducer() - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

CSVRecordReader - Class in com.aliyun.odps.mapred.local

CSVRecordReader(FileSplit, TableMeta, Counter, Counter, Counters, char) - Constructor for class com.aliyun.odps.mapred.local.CSVRecordReader

CSVRecordWriter - Class in com.aliyun.odps.mapred.local

CSVRecordWriter(File, Counter, Counter, char) - Constructor for class com.aliyun.odps.mapred.local.CSVRecordWriter

D

DriverBase - Class in com.aliyun.odps.mapred.local

E

EMPTY_COUNTER - Static variable in class com.aliyun.odps.mapred.LocalJobRunner

encoding - Static variable in class com.aliyun.odps.mapred.local.CSVRecordReader

equalRecords(List<Record>, List<Record>, boolean) - Static method in class com.aliyun.odps.mapred.unittest.MRUnitTest

比较两个记录列表是否相同（相等），记录比较见 RecordComparator.

equalRecords(File, List<Record>, boolean) - Static method in class com.aliyun.odps.mapred.unittest.MRUnitTest

比较给定本地目录下的记录集合和一个记录列表是否相同（相等），记录比较见 RecordComparator.

equals(Object) - Method in class com.aliyun.odps.mapred.unittest.KeyValue

G

generateLocalMrTaskName() - Static method in class com.aliyun.odps.mapred.local.utils.LocalMRUtils

generateMrTaskName() - Static method in class com.aliyun.odps.mapred.local.utils.LocalMRUtils

getAvgInputRecords() - Method in class com.aliyun.odps.mapred.local.StageStatic

getAvgOutputRecords() - Method in class com.aliyun.odps.mapred.local.StageStatic

getCombinerClass() - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

getComparator() - Method in class com.aliyun.odps.mapred.local.MapOutputBuffer

getConf() - Method in class com.aliyun.odps.mapred.LocalJobRunner

getCounter(Enum<?>) - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

getCounter(String, String) - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

getCounters() - Method in class com.aliyun.odps.mapred.local.DriverBase

getCounters() - Method in class com.aliyun.odps.mapred.local.LocalRunningJob

getCounters() - Method in class com.aliyun.odps.mapred.unittest.TaskOutput

获取作业 Counters.

getCurrentNode() - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

getDiagnostics() - Method in class com.aliyun.odps.mapred.local.LocalRunningJob

getGroupingColumns() - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

getInputDir(String, String) - Method in class com.aliyun.odps.mapred.unittest.RuntimeContext

getInputKeyVals() - Method in class com.aliyun.odps.mapred.unittest.ReduceUTContext

getInputRecords() - Method in class com.aliyun.odps.mapred.unittest.MapUTContext

获取 Map 输入的记录列表.

getInputSchema() - Method in class com.aliyun.odps.mapred.unittest.MapUTContext

getInstanceID() - Method in class com.aliyun.odps.mapred.local.LocalRunningJob

getJobConf() - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

getJobDir() - Method in class com.aliyun.odps.mapred.unittest.RuntimeContext

getJobFile() - Method in class com.aliyun.odps.mapred.unittest.RuntimeContext

getJobId() - Method in class com.aliyun.odps.mapred.unittest.RuntimeContext

getJobStatus() - Method in class com.aliyun.odps.mapred.local.LocalRunningJob

getKey() - Method in class com.aliyun.odps.mapred.unittest.KeyValue

getLen() - Method in class com.aliyun.odps.mapred.local.CSVRecordWriter

getMapOutputKeySchema() - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

getMapOutputValueSchema() - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

getMapperClass() - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

getMaxInputRecords() - Method in class com.aliyun.odps.mapred.local.StageStatic

getMaxOutputRecords() - Method in class com.aliyun.odps.mapred.local.StageStatic

getMinInputRecords() - Method in class com.aliyun.odps.mapred.local.StageStatic

getMinOutputRecords() - Method in class com.aliyun.odps.mapred.local.StageStatic

getNextTaskId() - Method in class com.aliyun.odps.mapred.local.StageStatic

getNumReduceTasks() - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

getOutputDir(String) - Method in class com.aliyun.odps.mapred.unittest.RuntimeContext

getOutputKeyValues() - Method in class com.aliyun.odps.mapred.unittest.TaskOutput

返回 Mapper 最终输出到 Reducer 的键值对列表.

getOutputKeyValues(int) - Method in class com.aliyun.odps.mapred.unittest.TaskOutput

返回 Mapper 输出到给定 reduceId 的键值对列表.

getOutputRecords() - Method in class com.aliyun.odps.mapred.unittest.TaskOutput

获取默认输出结果，返回 List<Record>.

getOutputRecords(String) - Method in class com.aliyun.odps.mapred.unittest.TaskOutput

获取给定标签的输出结果，返回 List<Record>.

getOutputRecords(boolean) - Method in class com.aliyun.odps.mapred.unittest.TaskOutput

获取默认输出结果，返回 List<Record>.

getOutputRecords(String, boolean) - Method in class com.aliyun.odps.mapred.unittest.TaskOutput

获取给定标签的输出结果，返回 List<Record>.

getOutputTableInfo() - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

getPartitionQueue(int) - Method in class com.aliyun.odps.mapred.local.MapOutputBuffer

getPipeline() - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

getReducerClass() - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

getReducerIndex() - Method in class com.aliyun.odps.mapred.unittest.ReduceUTContext

getResourceDir() - Method in class com.aliyun.odps.mapred.unittest.RuntimeContext

getTaskID() - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

getTaskId() - Method in class com.aliyun.odps.mapred.local.StageStatic

getTaskId() - Method in class com.aliyun.odps.mapred.unittest.UTContext

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

getTotalInputRecords() - Method in class com.aliyun.odps.mapred.local.StageStatic

getTotalOutputRecords() - Method in class com.aliyun.odps.mapred.local.StageStatic

getTotalRecordCount() - Method in class com.aliyun.odps.mapred.local.MapOutputBuffer

getTotalRecordCount() - Method in class com.aliyun.odps.mapred.unittest.TaskOutput

getValidator(BridgeJobConf) - Static method in class com.aliyun.odps.mapred.local.utils.LocalValidatorFactory

getValue() - Method in class com.aliyun.odps.mapred.unittest.KeyValue

getWareHouse() - Static method in class com.aliyun.odps.mapred.unittest.RuntimeContext

getWorkerCount() - Method in class com.aliyun.odps.mapred.local.StageStatic

H

hasNext() - Method in class com.aliyun.odps.mapred.local.LocalGroupingRecordIterator

I

initialize() - Method in class com.aliyun.odps.mapred.LocalJobRunner

isCleanUtDir() - Method in class com.aliyun.odps.mapred.unittest.UTContext

isComplete() - Method in class com.aliyun.odps.mapred.local.LocalRunningJob

isPipelineMode() - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

isSuccessful() - Method in class com.aliyun.odps.mapred.local.LocalRunningJob

J

JobCounter - Enum in com.aliyun.odps.mapred.local

K

KeyValue<K,V> - Class in com.aliyun.odps.mapred.unittest

键值对（Key/Value）.

KeyValue(K, V) - Constructor for class com.aliyun.odps.mapred.unittest.KeyValue

killJob() - Method in class com.aliyun.odps.mapred.local.LocalRunningJob

L

LocalColumnBasedRecordComparator - Class in com.aliyun.odps.mapred.local.utils

可以指定排序列的RecordComparator。排序策略是自然序。

LocalColumnBasedRecordComparator(int[], Column[], JobConf.SortOrder[]) - Constructor for class com.aliyun.odps.mapred.local.utils.LocalColumnBasedRecordComparator

ColumnBasedRecordComparator的构造方法，指定排序列的下标索引。例如指定排序列的下标索引为0，3，则比较时先用第0列比较， 第0列相同时使用第3列比较。

LocalColumnBasedRecordComparator(String[], Column[], JobConf.SortOrder[]) - Constructor for class com.aliyun.odps.mapred.local.utils.LocalColumnBasedRecordComparator

ColumnBasedRecordComparator的构造方法，指定排序列的列名。例如指定排序列的下标索引为“word”，“count”， 则比较时先用word列比较， word列相同时使用count列比较。

LocalGroupingRecordIterator - Class in com.aliyun.odps.mapred.local

LocalGroupingRecordIterator(Queue<Object[]>, WritableRecord, WritableRecord, Comparator<Object[]>, boolean, Counters) - Constructor for class com.aliyun.odps.mapred.local.LocalGroupingRecordIterator

LocalJobRunner - Class in com.aliyun.odps.mapred

LocalJobRunner() - Constructor for class com.aliyun.odps.mapred.LocalJobRunner

LocalMRUtils - Class in com.aliyun.odps.mapred.local.utils

LocalMRUtils() - Constructor for class com.aliyun.odps.mapred.local.utils.LocalMRUtils

LocalRecordComparator - Class in com.aliyun.odps.mapred.unittest

RecordComparator 用于对 Record 进行比较.

LocalRecordComparator() - Constructor for class com.aliyun.odps.mapred.unittest.LocalRecordComparator

LocalRunningJob - Class in com.aliyun.odps.mapred.local

LocalRunningJob(String, JobStatus, Counters) - Constructor for class com.aliyun.odps.mapred.local.LocalRunningJob

LocalTaskContext - Class in com.aliyun.odps.mapred.local

LocalTaskContext(BridgeJobConf, TaskId, Counters) - Constructor for class com.aliyun.odps.mapred.local.LocalTaskContext

LocalTaskId - Class in com.aliyun.odps.mapred.local

LocalTaskId(String, int, String) - Constructor for class com.aliyun.odps.mapred.local.LocalTaskId

LocalValidatorFactory - Class in com.aliyun.odps.mapred.local.utils

LocalValidatorFactory() - Constructor for class com.aliyun.odps.mapred.local.utils.LocalValidatorFactory

LOG - Static variable in class com.aliyun.odps.mapred.local.LocalTaskContext

LOG - Static variable in class com.aliyun.odps.mapred.local.MapDriver

LOG - Static variable in class com.aliyun.odps.mapred.local.ReduceDriver

M

MapDriver - Class in com.aliyun.odps.mapred.local

MapDriver(BridgeJobConf, FileSplit, TaskId, MapOutputBuffer, Counters, TableInfo) - Constructor for class com.aliyun.odps.mapred.local.MapDriver

MapOutputBuffer - Class in com.aliyun.odps.mapred.local

MapOutputBuffer(JobConf, int) - Constructor for class com.aliyun.odps.mapred.local.MapOutputBuffer

MapOutputBuffer(JobConf, Pipeline, String, int) - Constructor for class com.aliyun.odps.mapred.local.MapOutputBuffer

mapProgress() - Method in class com.aliyun.odps.mapred.local.LocalRunningJob

MapUTContext - Class in com.aliyun.odps.mapred.unittest

Mapper 单元测试的上下文.

MapUTContext() - Constructor for class com.aliyun.odps.mapred.unittest.MapUTContext

MRExceptionCode - Class in com.aliyun.odps.mapred.local

MRExceptionCode() - Constructor for class com.aliyun.odps.mapred.local.MRExceptionCode

MRUnitTest - Class in com.aliyun.odps.mapred.unittest

MapReduce 单元测试基类，方便用户编写 MapReduce 作业的单元测试用例.

MRUnitTest() - Constructor for class com.aliyun.odps.mapred.unittest.MRUnitTest

N

next() - Method in class com.aliyun.odps.mapred.local.LocalGroupingRecordIterator

O

ODPS_0110999 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0710005 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0710015 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0710025 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720001 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720015 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720021 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720031 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720041 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720051 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720061 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720071 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720081 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720091 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720101 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720111 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720121 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720131 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720141 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720151 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720161 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720171 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720181 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720191 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720201 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720211 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720221 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720231 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720241 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720251 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720261 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720271 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720281 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720291 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720301 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720311 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720321 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720331 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720341 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720351 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720361 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720371 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720381 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720411 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720431 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0720441 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0730005 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

ODPS_0740001 - Static variable in class com.aliyun.odps.mapred.local.MRExceptionCode

P

progress() - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

R

read() - Method in class com.aliyun.odps.mapred.local.CSVRecordReader

readRecords(File) - Static method in class com.aliyun.odps.mapred.unittest.MRUnitTest

从给定的本地目录读取记录.

readResourceArchiveAsStream(String) - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

readResourceArchiveAsStream(String, String) - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

readResourceFileAsStream(String) - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

readResourceTable(String) - Method in class com.aliyun.odps.mapred.local.LocalTaskContext

ReduceDriver - Class in com.aliyun.odps.mapred.local

ReduceDriver(BridgeJobConf, MapOutputBuffer, MapOutputBuffer, TaskId, Counters, int) - Constructor for class com.aliyun.odps.mapred.local.ReduceDriver

reduceProgress() - Method in class com.aliyun.odps.mapred.local.LocalRunningJob

ReduceUTContext - Class in com.aliyun.odps.mapred.unittest

Reducer 单元测试的上下文.

ReduceUTContext() - Constructor for class com.aliyun.odps.mapred.unittest.ReduceUTContext

remove() - Method in class com.aliyun.odps.mapred.local.LocalGroupingRecordIterator

reset() - Method in class com.aliyun.odps.mapred.local.LocalGroupingRecordIterator

run() - Method in class com.aliyun.odps.mapred.local.DriverBase

run() - Method in class com.aliyun.odps.mapred.local.MapDriver

run() - Method in class com.aliyun.odps.mapred.local.ReduceDriver

runMapper(JobConf, MapUTContext) - Method in class com.aliyun.odps.mapred.unittest.MRUnitTest

执行 Mapper 过程.

runReducer(JobConf, ReduceUTContext) - Method in class com.aliyun.odps.mapred.unittest.MRUnitTest

执行 Reducer 过程.

RuntimeContext - Class in com.aliyun.odps.mapred.unittest

S

setArchiveResource(String, File) - Method in class com.aliyun.odps.mapred.unittest.UTContext

定义压缩档案资源.

setAvgInputRecords(long) - Method in class com.aliyun.odps.mapred.local.StageStatic

setAvgOutputRecords(long) - Method in class com.aliyun.odps.mapred.local.StageStatic

setCleanUtDir(boolean) - Method in class com.aliyun.odps.mapred.unittest.UTContext

setConf(Configuration) - Method in class com.aliyun.odps.mapred.LocalJobRunner

setFileResource(String, File) - Method in class com.aliyun.odps.mapred.unittest.UTContext

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

setFileResource(String, String) - Method in class com.aliyun.odps.mapred.unittest.UTContext

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

setFileResource(String, byte[]) - Method in class com.aliyun.odps.mapred.unittest.UTContext

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

setInputRecordCount(long) - Method in class com.aliyun.odps.mapred.local.StageStatic

setInputSchema(String) - Method in class com.aliyun.odps.mapred.unittest.MapUTContext

设置 Map 输入的 schema.

setKey(K) - Method in class com.aliyun.odps.mapred.unittest.KeyValue

setMaxInputRecords(long) - Method in class com.aliyun.odps.mapred.local.StageStatic

setMaxOutputRecords(long) - Method in class com.aliyun.odps.mapred.local.StageStatic

setMinInputRecords(long) - Method in class com.aliyun.odps.mapred.local.StageStatic

setMinOutputRecords(long) - Method in class com.aliyun.odps.mapred.local.StageStatic

setNextTaskId(String) - Method in class com.aliyun.odps.mapred.local.StageStatic

setOutputRecordCount(long) - Method in class com.aliyun.odps.mapred.local.StageStatic

setOutputSchema(String, Configuration) - Method in class com.aliyun.odps.mapred.unittest.UTContext

设置默认输出的 schema.

setOutputSchema(String, String, Configuration) - Method in class com.aliyun.odps.mapred.unittest.UTContext

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

setReducerIndex(int) - Method in class com.aliyun.odps.mapred.unittest.ReduceUTContext

setTableResource(String, TableInfo, String, List<Record>) - Method in class com.aliyun.odps.mapred.unittest.UTContext

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

setTableResource(String, File) - Method in class com.aliyun.odps.mapred.unittest.UTContext

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

setTaskId(String) - Method in class com.aliyun.odps.mapred.local.StageStatic

setTaskId(int) - Method in class com.aliyun.odps.mapred.unittest.UTContext

设置 TaskId，不设默认为 0.

setTotalInputRecords(long) - Method in class com.aliyun.odps.mapred.local.StageStatic

setTotalOutputRecords(long) - Method in class com.aliyun.odps.mapred.local.StageStatic

setValue(V) - Method in class com.aliyun.odps.mapred.unittest.KeyValue

setWorkerCount(int) - Method in class com.aliyun.odps.mapred.local.StageStatic

StageStatic - Class in com.aliyun.odps.mapred.local

StageStatic() - Constructor for class com.aliyun.odps.mapred.local.StageStatic

submit() - Method in class com.aliyun.odps.mapred.LocalJobRunner

T

TaskOutput - Class in com.aliyun.odps.mapred.unittest

Mapper/Reducer的输出.

TaskOutput(JobConf, int) - Constructor for class com.aliyun.odps.mapred.unittest.TaskOutput

TaskOutput(JobConf, Pipeline, String, int) - Constructor for class com.aliyun.odps.mapred.unittest.TaskOutput

throwException(ErrorCode, Throwable) - Static method in class com.aliyun.odps.mapred.local.utils.LocalValidatorFactory

toString() - Method in class com.aliyun.odps.mapred.local.LocalTaskId

toString() - Method in class com.aliyun.odps.mapred.unittest.KeyValue

U

UTContext - Class in com.aliyun.odps.mapred.unittest

MapReduce Unit Test 上下文基类.

UTContext() - Constructor for class com.aliyun.odps.mapred.unittest.UTContext

V

valueOf(String) - Static method in enum com.aliyun.odps.mapred.local.JobCounter

Returns the enum constant of this type with the specified name.

values() - Static method in enum com.aliyun.odps.mapred.local.JobCounter

Returns an array containing the constants of this enum type, in the order they are declared.

W

waitForCompletion() - Method in class com.aliyun.odps.mapred.local.LocalRunningJob

write(Record) - Method in class com.aliyun.odps.mapred.local.CSVRecordWriter

write(RecordPack) - Method in class com.aliyun.odps.mapred.local.CSVRecordWriter

writeRecords(File, List<Record>, TableMeta) - Static method in class com.aliyun.odps.mapred.unittest.MRUnitTest

将记录写到给定的本地目录.

A C D E G H I J K L M N O P R S T U V W