MaxCompute用户指南：MapReduce：Java SDK：兼容版本SDK概述
MaxCompute 兼容版本的 MapReduce 与 Hadoop MapReduce 兼容性的详细列表，如下表所示：
| 类型 | 接口 | 是否兼容 |
| Mapper | void map(KEYIN key, VALUEIN value, org.apache.hadoop.mapreduce.Mapper.Context context) | 是 |
| Mapper | void run(org.apache.hadoop.mapreduce.Mapper.Context context) | 是 |
| Mapper | void setup(org.apache.hadoop.mapreduce.Mapper.Context context) | 是 |
| Reducer | void cleanup(org.apache.hadoop.mapreduce.Reducer.Context context) | 是 |
| Reducer | void reduce(KEYIN key, VALUEIN value, org.apache.hadoop.mapreduce.Reducer.Context context) | 是 |
| Reducer | void run(org.apache.hadoop.mapreduce.Reducer.Context context) | 是 |
| Reducer | void setup(org.apache.hadoop.mapreduce.Reducer.Context context) | 是 |
| Partitioner | int getPartition(KEY key, VALUE value, int numPartitions) | 是 |
| MapContext（继承TaskInputOutputContext） | InputSplit getInputSplit() | 否，抛异常 |
| ReduceContext | nextKey() | 是 |
| ReduceContext | getValues() | 是 |
| TaskInputOutputContext | getCurrentKey() | 是 |
| TaskInputOutputContext | getCurrentValue() | 是 |
| TaskInputOutputContext | getOutputCommitter() | 否，抛异常 |
| TaskInputOutputContext | nextKeyValue() | 是 |
| TaskInputOutputContext | write(KEYOUT key, VALUEOUT value) | 是 |
| TaskAttemptContext | getCounter(Enum<?> counterName) | 是 |
| TaskAttemptContext | getCounter(String groupName, String counterName) | 是 |
| TaskAttemptContext | setStatus(String msg) | 空实现 |
| TaskAttemptContext | getStatus() | 空实现 |
| TaskAttemptContext | getTaskAttemptID() | 否，抛异常 |
| TaskAttemptContext | getProgress() | 否，抛异常 |
| TaskAttemptContext | progress() | 是 |
| Job | addArchiveToClassPath(Path archive) | 否 |
| Job | addCacheArchive(URI uri) | 否 |
| Job | addCacheFile(URI uri) | 否 |
| Job | addFileToClassPath(Path file) | 否 |
| Job | cleanupProgress() | 否 |
| Job | createSymlink() | 否，抛异常 |
| Job | failTask(TaskAttemptID taskId) | 否 |
| Job | getCompletionPollInterval(Configuration conf) | 空实现 |
| Job | getCounters() | 是 |
| Job | getFinishTime() | 是 |
| Job | getHistoryUrl() | 是 |
| Job | getInstance() | 是 |
| Job | getInstance(Cluster ignored) | 是 |
| Job | getInstance(Cluster ignored, Configuration conf) | 是 |
| Job | getInstance(Configuration conf) | 是 |
| Job | getInstance(Configuration conf, String jobName) | 空实现 |
| Job | getInstance(JobStatus status, Configuration conf) | 否，抛异常 |
| Job | getJobFile() | 否，抛异常 |
| Job | getJobName() | 空实现 |
| Job | getJobState() | 否，抛异常 |
| Job | getPriority() | 否，抛异常 |
| Job | getProgressPollInterval(Configuration conf) | 空实现 |
| Job | getReservationId() | 否，抛异常 |
| Job | getSchedulingInfo() | 否，抛异常 |
| Job | getStartTime() | 是 |
| Job | getStatus() | 否，抛异常 |
| Job | getTaskCompletionEvents(int startFrom) | 否，抛异常 |
| Job | getTaskCompletionEvents(int startFrom, int numEvents) | 否，抛异常 |
| Job | getTaskDiagnostics(TaskAttemptID taskid) | 否，抛异常 |
| Job | getTaskOutputFilter(Configuration conf) | 否，抛异常 |
| Job | getTaskReports(TaskType type) | 否，抛异常 |
| Job | getTrackingURL() | 是 |
| Job | isComplete() | 是 |
| Job | isRetired() | 否，抛异常 |
| Job | isSuccessful() | 是 |
| Job | isUber() | 空实现 |
| Job | killJob() 是 | |
| Job | killTask(TaskAttemptID taskId) | 否 |
| Job | mapProgress() | 是 |
| Job | monitorAndPrintJob() | 是 |
| Job | reduceProgress() | 是 |
| Job | setCacheArchives(URI[] archives) | 否，抛异常 |
| Job | setCacheFiles(URI[] files) | 否，抛异常 |
| Job | setCancelDelegationTokenUponJobCompletion(boolean value) | 否，抛异常 |
| Job | setCombinerClass(Class<? extends Reducer> cls) | 是 |
| Job | setCombinerKeyGroupingComparatorClass(Class<? extends RawComparator> cls) | 是 |
| Job | setGroupingComparatorClass(Class<? extends RawComparator> cls) | 是 |
| Job | setInputFormatClass(Class<? extends InputFormat> cls) | 空实现 |
| Job | setJar(String jar) | 是 |
| Job | setJarByClass(Class<?> cls) | 是 |
| Job | setJobName(String name) | 空实现 |
| Job | setJobSetupCleanupNeeded(boolean needed) | 空实现 |
| Job | setMapOutputKeyClass(Class<?> theClass) | 是 |
| Job | setMapOutputValueClass(Class<?> theClass) | 是 |
| Job | setMapperClass(Class<? extends Mapper> cls) | 是 |
| Job | setMapSpeculativeExecution(boolean speculativeExecution) | 空实现 |
| Job | setMaxMapAttempts(int n) | 空实现 |
| Job | setMaxReduceAttempts(int n) | 空实现 |
| Job | setNumReduceTasks(int tasks) | 是 |
| Job | setOutputFormatClass(Class<? extends OutputFormat> cls) | 否，抛异常 |
| Job | setOutputKeyClass(Class<?> theClass) | 是 |
| Job | setOutputValueClass(Class<?> theClass) | 是 |
| Job | setPartitionerClass(Class<? extends Partitioner> cls) | 是 |
| Job | setPriority(JobPriority priority) | 否，抛异常 |
| Job | setProfileEnabled(boolean newValue) | 空实现 |
| Job | setProfileParams(String value) | 空实现 |
| Job | setProfileTaskRange(boolean isMap, String newValue) | 空实现 |
| Job | setReducerClass(Class<? extends Reducer> cls) | 是 |
| Job | setReduceSpeculativeExecution(boolean speculativeExecution) | 空实现 |
| Job | setReservationId(ReservationId reservationId) | 否，抛异常 |
| Job | setSortComparatorClass(Class<? extends RawComparator> cls) | 否，抛异常 |
| Job | setSpeculativeExecution(boolean speculativeExecution) | 是 |
| Job | setTaskOutputFilter(Configuration conf, org.apache.hadoop.mapreduce.Job.TaskStatusFilter newValue) | 否，抛异常 |
| Job | setupProgress() | 否，抛异常 |
| Job | setUser(String user) | 空实现 |
| Job | setWorkingDirectory(Path dir) | 空实现 |
| Job | submit() | 是 |
| Job | toString() | 否，抛异常 |
| Job | waitForCompletion(boolean verbose) | 是 |
| Task Execution & Environment | mapreduce.map.java.opts | 空实现 |
| Task Execution & Environment | mapreduce.reduce.java.opts | 空实现 |
| Task Execution & Environment | mapreduce.map.memory.mb | 空实现 |
| Task Execution & Environment | mapreduce.reduce.memory.mb | 空实现 |
| Task Execution & Environment | mapreduce.task.io.sort.mb | 空实现 |
| Task Execution & Environment | mapreduce.map.sort.spill.percent | 空实现 |
| Task Execution & Environment | mapreduce.task.io.soft.factor | 空实现 |
| Task Execution & Environment | mapreduce.reduce.merge.inmem.thresholds | 空实现 |
| Task Execution & Environment | mapreduce.reduce.shuffle.merge.percent | 空实现 |
| Task Execution & Environment | mapreduce.reduce.shuffle.input.buffer.percent | 空实现 |
| Task Execution & Environment | mapreduce.reduce.input.buffer.percent | 空实现 |
| Task Execution & Environment | mapreduce.job.id | 空实现 |
| Task Execution & Environment | mapreduce.job.jar | 空实现 |
| Task Execution & Environment | mapreduce.job.local.dir | 空实现 |
| Task Execution & Environment | mapreduce.task.id | 空实现 |
| Task Execution & Environment | mapreduce.task.attempt.id | 空实现 |
| Task Execution & Environment | mapreduce.task.is.map | 空实现 |
| Task Execution & Environment | mapreduce.task.partition | 空实现 |
| Task Execution & Environment | mapreduce.map.input.file | 空实现 |
| Task Execution & Environment | mapreduce.map.input.start | 空实现 |
| Task Execution & Environment | mapreduce.map.input.length | 空实现 |
| Task Execution & Environment | mapreduce.task.output.dir | 空实现 |
| JobClient | cancelDelegationToken(Token token) | 否，抛异常 |
| JobClient | close() | 空实现 |
| JobClient | displayTasks(JobID jobId, String type, String state) | 否，抛异常 |
| JobClient | getAllJobs() | 否，抛异常 |
| JobClient | getCleanupTaskReports(JobID jobId) | 否，抛异常 |
| JobClient | getClusterStatus() | 否，抛异常 |
| JobClient | getClusterStatus(boolean detailed) | 否，抛异常 |
| JobClient | getDefaultMaps() | 否，抛异常 |
| JobClient | getDefaultReduces() | 否，抛异常 |
| JobClient | getDelegationToken(Text renewer) | 否，抛异常 |
| JobClient | getFs() | 否，抛异常 |
| JobClient | getJob(JobID jobid) | 否，抛异常 |
| JobClient | getJob(String jobid) | 否，抛异常 |
| JobClient | getJobsFromQueue(String queueName) | 否，抛异常 |
| JobClient | getMapTaskReports(JobID jobId) | 否，抛异常 |
| JobClient | getMapTaskReports(String jobId) | 否，抛异常 |
| JobClient | getQueueAclsForCurrentUser() | 否，抛异常 |
| JobClient | getQueueInfo(String queueName) | 否，抛异常 |
| JobClient | getQueues() | 否，抛异常 |
| JobClient | getReduceTaskReports(JobID jobId) | 否，抛异常 |
| JobClient | getReduceTaskReports(String jobId) | 否，抛异常 |
| JobClient | getSetupTaskReports(JobID jobId) | 否，抛异常 |
| JobClient | getStagingAreaDir() | 否，抛异常 |
| JobClient | getSystemDir() | 否，抛异常 |
| JobClient | getTaskOutputFilter() | 否，抛异常 |
| JobClient | getTaskOutputFilter(JobConf job) | 否，抛异常 |
| JobClient | init(JobConf conf) | 否，抛异常 |
| JobClient | isJobDirValid(Path jobDirPath, FileSystem fs) | 否，抛异常 |
| JobClient | jobsToComplete() | 否，抛异常 |
| JobClient | monitorAndPrintJob(JobConf conf, RunningJob job) | 否，抛异常 |
| JobClient | renewDelegationToken(Token token) | 否，抛异常 |
| JobClient | run(String[] argv) | 否，抛异常 |
| JobClient | runJob(JobConf job) | 是 |
| JobClient | setTaskOutputFilter(JobClient.TaskStatusFilter newValue) | 否，抛异常 |
| JobClient | setTaskOutputFilter(JobConf job, JobClient.TaskStatusFilter newValue) | 否，抛异常 |
| JobClient | submitJob(JobConf job) | 是 |
| JobClient | submitJob(String jobFile) | 否，抛异常 |
| JobConf | deleteLocalFiles() | 否，抛异常 |
| JobConf | deleteLocalFiles(String subdir) | 否，抛异常 |
| JobConf | normalizeMemoryConfigValue(long val) | 空实现 |
| JobConf | setCombinerClass(Class<? extends Reducer> theClass) | 是 |
| JobConf | setCompressMapOutput(boolean compress) | 空实现 |
| JobConf | setInputFormat(Class<? extends InputFormat> theClass) | 否，抛异常 |
| JobConf | setJar(String jar) | 否，抛异常 |
| JobConf | setJarByClass(Class cls) | 否，抛异常 |
| JobConf | setJobEndNotificationURI(String uri) | 否，抛异常 |
| JobConf | setJobName(String name) | 空实现 |
| JobConf | setJobPriority(JobPriority prio) | 否，抛异常 |
| JobConf | setKeepFailedTaskFiles(boolean keep) | 否，抛异常 |
| JobConf | setKeepTaskFilesPattern(String pattern) | 否，抛异常 |
| JobConf | setKeyFieldComparatorOptions(String keySpec) | 否，抛异常 |
| JobConf | setKeyFieldPartitionerOptions(String keySpec) | 否，抛异常 |
| JobConf | setMapDebugScript(String mDbgScript) | 空实现 |
| JobConf | setMapOutputCompressorClass(Class<? extends CompressionCodec> codecClass) | 空实现 |
| JobConf | setMapOutputKeyClass(Class<?> theClass) | 是 |
| JobConf | setMapOutputValueClass(Class<?> theClass) | 是 |
| JobConf | setMapperClass(Class<? extends Mapper> theClass) | 是 |
| JobConf | setMapRunnerClass(Class<? extends MapRunnable> theClass) | 否，抛异常 |
| JobConf | setMapSpeculativeExecution(boolean speculativeExecution) | 空实现 |
| JobConf | setMaxMapAttempts(int n) | 空实现 |
| JobConf | setMaxMapTaskFailuresPercent(int percent) | 空实现 |
| JobConf | setMaxPhysicalMemoryForTask(long mem) | 空实现 |
| JobConf | setMaxReduceAttempts(int n) | 空实现 |
| JobConf | setMaxReduceTaskFailuresPercent(int percent) | 空实现 |
| JobConf | setMaxTaskFailuresPerTracker(int noFailures) | 空实现 |
| JobConf | setMaxVirtualMemoryForTask(long vmem) | 空实现 |
| JobConf | setMemoryForMapTask(long mem) | 是 |
| JobConf | setMemoryForReduceTask(long mem) | 是 |
| JobConf | setNumMapTasks(int n) | 是 |
| JobConf | setNumReduceTasks(int n) | 是 |
| JobConf | setNumTasksToExecutePerJvm(int numTasks) | 空实现 |
| JobConf | setOutputCommitter(Class<? extends OutputCommitter> theClass) | 否，抛异常 |
| JobConf | setOutputFormat(Class<? extends OutputFormat> theClass) | 空实现 |
| JobConf | setOutputKeyClass(Class<?> theClass) | 是 |
| JobConf | setOutputKeyComparatorClass(Class<? extends RawComparator> theClass) | 否，抛异常 |
| JobConf | setOutputValueClass(Class<?> theClass) | 是 |
| JobConf | setOutputValueGroupingComparator(Class<? extends RawComparator> theClass) | 否，抛异常 |
| JobConf | setPartitionerClass(Class<? extends Partitioner> theClass) | 是 |
| JobConf | setProfileEnabled(boolean newValue) | 空实现 |
| JobConf | setProfileParams(String value) | 空实现 |
| JobConf | setProfileTaskRange(boolean isMap, String newValue) | 空实现 |
| JobConf | setQueueName(String queueName) | 否，抛异常 |
| JobConf | setReduceDebugScript(String rDbgScript) | 空实现 |
| JobConf | setReducerClass(Class<? extends Reducer> theClass) | 是 |
| JobConf | setReduceSpeculativeExecution(boolean speculativeExecution) | 空实现 |
| JobConf | setSessionId(String sessionId) | 空实现 |
| JobConf | setSpeculativeExecution(boolean speculativeExecution) | 否，抛异常 |
| JobConf | setUseNewMapper(boolean flag) | 是 |
| JobConf | setUseNewReducer(boolean flag) | 是 |
| JobConf | setUser(String user) | 空实现 |
| JobConf | setWorkingDirectory(Path dir) | 空实现 |
| FileInputFormat | 否，抛异常 | |
| TextInputFormat | 是 | |
| InputSplit | 否，抛异常 | |
| mapred.min.split.size. | 否，抛异常 | |
| FileSplit | 否，抛异常 | |
| map.input.file | 否，抛异常 | |
| RecordWriter | 否，抛异常 | |
| RecordReader | 否，抛异常 | |
| OutputFormat | 否，抛异常 | |
| OutputCommitter | abortJob(JobContext jobContext, int status) | 否，抛异常 |
| OutputCommitter | abortJob(JobContext context, JobStatus.State runState) | 否，抛异常 |
| OutputCommitter | abortTask(TaskAttemptContext taskContext) | 否，抛异常 |
| OutputCommitter | abortTask(TaskAttemptContext taskContext) | 否，抛异常 |
| OutputCommitter | cleanupJob(JobContext jobContext) | 否，抛异常 |
| OutputCommitter | cleanupJob(JobContext context) | 否，抛异常 |
| OutputCommitter | commitJob(JobContext jobContext) | 否，抛异常 |
| OutputCommitter | commitJob(JobContext context) | 否，抛异常 |
| OutputCommitter | commitTask(TaskAttemptContext taskContext) | 否，抛异常 |
| OutputCommitter | needsTaskCommit(TaskAttemptContext taskContext) | 否，抛异常 |
| OutputCommitter | needsTaskCommit(TaskAttemptContext taskContext) | 否，抛异常 |
| OutputCommitter | setupJob(JobContext jobContext) | 否，抛异常 |
| OutputCommitter | setupJob(JobContext jobContext) | 否，抛异常 |
| OutputCommitter | setupTask(TaskAttemptContext taskContext) | 否，抛异常 |
| OutputCommitter | setupTask(TaskAttemptContext taskContext) | 否，抛异常 |
| Counter | getDisplayName() | 是 |
| Counter | getName() | 是 |
| Counter | getValue() | 是 |
| Counter | increment(long incr) | 是 |
| Counter | setValue(long value) | 是 |
| Counter | setDisplayName(String displayName) | 是 |
| DistributedCache | CACHE_ARCHIVES | 否，抛异常 |
| DistributedCache | CACHE_ARCHIVES_SIZES | 否，抛异常 |
| DistributedCache | CACHE_ARCHIVES_TIMESTAMPS | 否，抛异常 |
| DistributedCache | CACHE_FILES | 否，抛异常 |
| DistributedCache | CACHE_FILES_SIZES | 否，抛异常 |
| DistributedCache | CACHE_FILES_TIMESTAMPS | 否，抛异常 |
| DistributedCache | CACHE_LOCALARCHIVES | 否，抛异常 |
| DistributedCache | CACHE_LOCALFILES | 否，抛异常 |
| DistributedCache | CACHE_SYMLINK | 否，抛异常 |
| DistributedCache | addArchiveToClassPath(Path archive, Configuration conf) | 否，抛异常 |
| DistributedCache | addArchiveToClassPath(Path archive, Configuration conf, FileSystem fs) | 否，抛异常 |
| DistributedCache | addCacheArchive(URI uri, Configuration conf) | 否，抛异常 |
| DistributedCache | addCacheFile(URI uri, Configuration conf) | 否，抛异常 |
| DistributedCache | addFileToClassPath(Path file, Configuration conf) | 否，抛异常 |
| DistributedCache | addFileToClassPath(Path file, Configuration conf, FileSystem fs) | 否，抛异常 |
| DistributedCache | addLocalArchives(Configuration conf, String str) | 否，抛异常 |
| DistributedCache | addLocalFiles(Configuration conf, String str) | 否，抛异常 |
| DistributedCache | checkURIs(URI[] uriFiles, URI[] uriArchives) | 否，抛异常 |
| DistributedCache | createAllSymlink(Configuration conf, File jobCacheDir, File workDir) | 否，抛异常 |
| DistributedCache | createSymlink(Configuration conf) | 否，抛异常 |
| DistributedCache | getArchiveClassPaths(Configuration conf) | 否，抛异常 |
| DistributedCache | getArchiveTimestamps(Configuration conf) | 否，抛异常 |
| DistributedCache | getCacheArchives(Configuration conf) | 否，抛异常 |
| DistributedCache | getCacheFiles(Configuration conf) | 否，抛异常 |
| DistributedCache | getFileClassPaths(Configuration conf) | 否，抛异常 |
| DistributedCache | getFileStatus(Configuration conf, URI cache) | 否，抛异常 |
| DistributedCache | getFileTimestamps(Configuration conf) | 否，抛异常 |
| DistributedCache | getLocalCacheArchives(Configuration conf) | 否，抛异常 |
| DistributedCache | getLocalCacheFiles(Configuration conf) | 否，抛异常 |
| DistributedCache | getSymlink(Configuration conf) | 否，抛异常 |
| DistributedCache | getTimestamp(Configuration conf, URI cache) | 否，抛异常 |
| DistributedCache | setArchiveTimestamps(Configuration conf, String timestamps) | 否，抛异常 |
| DistributedCache | setCacheArchives(URI[] archives, Configuration conf) | 否，抛异常 |
| DistributedCache | setCacheFiles(URI[] files, Configuration conf) | 否，抛异常 |
| DistributedCache | setFileTimestamps(Configuration conf, String timestamps) | 否，抛异常 |
| DistributedCache | setLocalArchives(Configuration conf, String str) | 否，抛异常 |
| DistributedCache | setLocalFiles(Configuration conf, String str) | 否，抛异常 |
| IsolationRunner | 否，抛异常 | |
| Profiling | 空实现 | |
| Debugging | 空实现 | |
| Data Compression | 是 | |
| Skipping Bad Records | 否，抛异常 | |
| Job Authorization | mapred.acls.enabled | 否，抛异常 |
| Job Authorization | mapreduce.job.acl-view-job | 否，抛异常 |
| Job Authorization | mapreduce.job.acl-modify-job | 否，抛异常 |
| Job Authorization | mapreduce.cluster.administrators | 否，抛异常 |
| Job Authorization | mapred.queue.queue-name.acl-administer-jobs | 否，抛异常 |
| MultipleInputs | 否，抛异常 | |
| Multi{anchor:_GoBack}pleOutputs | 是 | |
| org.apache.hadoop.mapreduce.lib.db | 否，抛异常 | |
| org.apache.hadoop.mapreduce.security | 否，抛异常 | |
| org.apache.hadoop.mapreduce.lib.jobcontrol | 否，抛异常 | |
| org.apache.hadoop.mapreduce.lib.chain | 否，抛异常 | |
| org.apache.hadoop.mapreduce.lib.db | 否，抛异常 |
展开
收起
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
